Использование JNDI для расширенного объекта BasicDataSource
Я хочу реализовать пул соединений на моем соединении jdbc с использованием jndi, но я также хочу использовать расширенный объект 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
1 ответ
Хорошо, вот альтернатива, которую я делаю прямо сейчас. Я удалил ресурс JNDI и создал новый объект BasicDataSource непосредственно в моем сервлете вместо того, чтобы генерировать его из вызова метода фабрики JNDI. Для того, чтобы настроить можно я могу параметризовать свойства с помощью файла свойств?
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);