Драйвер
JSQLConnect поставляется с уже готовым пулом соединений. И почему бы его не использовать? :)
К тому же класс, который будет управлять этим пулом очень прост:
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.
75.
76.
77.
78.
79.
80.
81.
82.
83.
84.
85.
86.
87.
88.
89.
90.
91.
92.
93.
94.
95.
96.
97.
98.
99.
100.
101.
102.
103.
104.
105.
106.
107.
108.
109.
110.
111.
112.
113.
114.
115.
116.
117.
118.
119.
120.
121.
122.
123.
124.
package net.agrasoff.db;
import com.jnetdirect.jsql.*;
import java.util.*;
import java.sql.*;
public class JSQLDatabaseManager {
// грубо говоря, наш мэнеджер пулов является Singleton'ом
// но чтобы обеспечить управление несколькими пулами
// например, необходимо из одного приложения иметь
// коннекты к разным БД, мы храним экземпляры JSQLDatabaseManager
// в хэш-таблице managers, где ключем является уникальное название
// нашего менеджера, а значеним - сам менеджер
private static Hashtable managers = new Hashtable();
/* собственно - сам пул соединений */
private JSQLPoolingDataSource pool;
private boolean isInit;
private JSQLDatabaseManager() {
isInit = false;
}
public static JSQLDatabaseManager getInstance(String name) {
JSQLDatabaseManager manager = (JSQLDatabaseManager) managers.get(name);
if (manager == null ) {
manager = new JSQLDatabaseManager();
managers.put(name, manager);
}
return manager;
}
public Connection getConnection() throws SQLException {
if (pool == null || !isInit) {
throw new SQLException("Pool was not initialized");
}
return pool.getConnection();
}
public static Connection getConnection(String managerName) throws SQLException {
JSQLDatabaseManager manager = getInstance(managerName);
return manager.getConnection();
}
/* инициализация пула */
public void init(Properties properties) throws SQLException {
String url = properties.getProperty(POOL_URL);
String database = properties.getProperty(POOL_DATABASE);
String user = properties.getProperty(POOL_USER);
String password = properties.getProperty(POOL_PASSWORD);
String codepage = properties.getProperty(POOL_CODEPAGE);
if (Check.empty(codepage)) {
codepage = "Cp1251";
}
int initialPoolSize = 0 ;
try {
initialPoolSize = Integer.parseInt(properties.getProperty(POOL_INITIAL_SIZE));
} catch (Exception e) {
}
int minPoolSize = 5 ;
try {
minPoolSize = Integer.parseInt(properties.getProperty(POOL_MIN_SIZE));
} catch (Exception e) {
}
int maxPoolSize = 25 ;
try {
maxPoolSize = Integer.parseInt(properties.getProperty(POOL_MAX_SIZE));
} catch (Exception e) {
}
if (pool != null ) {
pool.closeAllConnections();
}
pool = new JSQLPoolingDataSource();
pool.setApplicationName(POOL_APPLICATION);
pool.setCodepage(codepage);
pool.setDatabaseName(database);
pool.setInitialPoolSize(initialPoolSize);
pool.setMaxPoolSize(maxPoolSize);
pool.setMinPoolSize(minPoolSize);
pool.setPassword(password);
pool.setUser(user);
pool.setUrl(url);
isInit = true;
}
public void close() throws SQLException {
if (pool != null ) {
isInit = false;
pool.closeAllConnections();
pool = null ;
}
}
public static void closePools() throws Exception {
Enumeration e = managers.keys();
while (e.hasMoreElements()) {
JSQLDatabaseManager manager = (JSQLDatabaseManager) e.nextElement();
manager.close();
}
managers.clear();
}
public static final String POOL_APPLICATION = "My Extra Web Application, v.6.66";
public static final String POOL_URL = "pool-url";
public static final String POOL_DATABASE = "pool-database";
public static final String POOL_USER = "pool-user";
public static final String POOL_PASSWORD = "pool-password";
public static final String POOL_CODEPAGE = "pool-codepage";
public static final String POOL_INITIAL_SIZE = "pool-initial-size";
public static final String POOL_MIN_SIZE = "pool-min-size";
public static final String POOL_MAX_SIZE = "pool-max-size";
}
вот и все. теперь использование. первое, что надо сделать - инициализировать
наш определенный пул. например, в неком стартап-сервлете:
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
...
public SetupServlet extends HttpServlet {
public void init() {
Properties connectionPoolProps = new Properties();
connectionPoolProps.setProperty(JSQLDatabaseManager.POOL_URL, "jdbc:....");
...
// и так далее - остальные свойства
// я, например, свойства пулов храню в одном xml-файле
// и вызываю статический метод JSQLDatabaseManager.initPools(String xmlPath)
// (данный метод не показан в приведенном выше коде)
...
JSQLDatabaseManager.getInstance("base content pool").init(connectionPoolProps);
// еще один пул:
Properties otherConnectionPoolProps = new Properties();
otherConnectionPoolProps.setProperty(JSQLDatabaseManager.POOL_URL, "jdbc:....");
...
JSQLDatabaseManager.getInstance("stat pool").init(otherConnectionPoolProps);
}
}
теперь мы имеем два готовых к использованию пула. и можем их использовать:
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
...
public SomeServlet extends HttpServlet {
...
public void service(...) ... {
try {
Connection con = JSQLDatabaseManager.getInstance("stat pool").getConnection();
// можно получить connection более кратко:
// Connection con = JSQLDatabaseManager.getConnection("stat pool");
try {
Statement st = con.createStatement();
ResultSet rs = st.executeQuery("select ...");
...
rs.close();
st.close();
} finally {
con.close();
}
} catch (SQLException e) {
log("...", e);
throw new ServletException(e.getMessage());
}
}
}
вот и все :)
