0

jndi を使用して jdbc 接続に接続プールを実装したいのですが、拡張された BasicDataSource オブジェクトも使用したいと考えています。Tomcat 5.5 の使用に制限があります。要件は、jndi コンテキスト リソース属性で提供されるパスワードを暗号化/復号化することです。

この投稿リンクに似たものを実装しようとしています

これは、BasicDataSource を拡張しなくても完全に機能する私のサーブレットです。

public class ReturnBlobOld extends HttpServlet {
    private static final long serialVersionUID = 1L;
    private org.apache.tomcat.dbcp.dbcp.BasicDataSource ds = null;
    // this is my extended DS which is not working
    //private custompages.NewBasicDataSource ds = null;

    public void init(ServletConfig config) throws ServletException {
        super.init(config);
        getDataSource();
    }

    public void getDataSource() {
        Context ctxt = null;
        try {
            ctxt = new InitialContext();
            ds = (BasicDataSource) ctxt.lookup("java:comp/env/jdbc/mysql");
          //ds = (NewBasicDataSource) ctxt.lookup("java:comp/env/jdbc/mysql");          
        ctxt.close();
        } catch (NamingException e) {
            e.printStackTrace();
        }
    }

    public void doGet(....){
           ........
          Connection connection = null;
          Statement statement = null;
        ResultSet res = null;
    try {
        connection = ds.getConnection();
        statement = connection.createStatement();
           }
     ................

これが私の拡張 BasicDataSource クラスです

package custompages;
import java.sql.SQLException;
import javax.sql.DataSource;
import org.apache.tomcat.dbcp.dbcp.BasicDataSource;

public class NewBasicDataSource extends BasicDataSource {

    protected synchronized DataSource createDataSource() throws SQLException {
        String decryptedPassword = decryptPassword( super.getPassword() );
        super.setPassword( decryptedPassword );
        return super.createDataSource();
    }
    private String decryptPassword( String password ) {
        return "abcdef";//logic to decrypt current password
    }
}

ここに私のcontext.xmlファイルがあります

<context>
<Resource name="jdbc/mysql"
auth="Container"
type="javax.sql.DataSource"
username="root"
password="abcdef"
driverClassName="com.mysql.jdbc.Driver"
url="jdbc:mysql://192.168.2.2:3306/world"
maxActive="1"
maxIdle="1"
maxWait="5000"
timeBetweenEvictionRunsMillis="5000"
minEvictableIdleTimeMillis="100"
removeAbandoned="true"
removeAbandonedTimeout="3"/>
</context>

これが私のWEB-INFリソース宣言です

<resource-ref>
<res-ref-name>jdbc/mysql</res-ref-name>
<res-type>javax.sql.DataSource</res-type>
<res-auth>Container</res-auth>
</resource-ref>

私のサーブレットは正常に動作し、上記のコードを使用して jdbc プールを初期化できます。しかし、パスワードの暗号化と復号化に拡張クラスを使用しようとすると、以下のような例外が発生します。

java.lang.ClassCastException: org.apache.tomcat.dbcp.dbcp.BasicDataSource
custompages.ReturnBlobOld.getDataSource(ReturnBlobOld.java:39)
custompages.ReturnBlobOld.init(ReturnBlobOld.java:32)
org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:117)
org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:174)
org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:881)
org.apache.coyote.http11.Http11BaseProtocol$Http11ConnectionHandler.processConnection(Http11BaseProtocol.java:674)
org.apache.tomcat.util.net.PoolTcpEndpoint.processSocket(PoolTcpEndpoint.java:541)
org.apache.tomcat.util.net.LeaderFollowerWorkerThread.runIt(LeaderFollowerWorkerThread.java:81)
org.apache.tomcat.util.threads.ThreadPool$ControlRunnable.run(ThreadPool.java:689)
java.lang.Thread.run(Thread.java:595)

jndi で使用するためにこのクラスを拡張する適切な方法を提案してください

4

1 に答える 1

0

わかりました、これが私が今やっている代替手段です。JNDI リソースを削除し、JNDI ファクトリ メソッド呼び出しから生成される代わりに、サーブレットで直接新しい BasicDataSource オブジェクトを作成しました。カスタマイズするには、プロパティ ファイルを使用してプロパティをパラメータ化できますか?

    public void getDataSource() {

        ds = new BasicDataSource();
        ds.setDriverClassName("com.mysql.jdbc.Driver");
        ds.setUsername("root");
        ds.setPassword("abcde");
        ds.setUrl("jdbc:mysql://192.168.2.2:3306/world");
        ds.setMaxActive(8);
        ds.setMaxIdle(8);
        ds.setMaxWait(10000);
        ds.setTimeBetweenEvictionRunsMillis(300000);
        ds.setMinEvictableIdleTimeMillis(1800000);
        ds.setRemoveAbandonedTimeout(300);
        ds.setRemoveAbandoned(true);
于 2013-06-11T19:31:31.913 に答える