Easyconnectionpool2.0

1. packagecom.mdj.dmdatabase.develop;
3. importjava.io.PrintWriter;
4. importjava.io.Serializable;
5. importjava.io.UnsupportedEncodingException;
6. importjava.sql.Connection;
7. importjava.sql.ResultSet;
8. importjava.sql.SQLException;
9. importjava.util.List;
10. importjava.util.Map;
11. importjava.util.Vector;
13. importjavax.sql.DataSource;
15. /**
16. *@seeConnectionpoolEasyconnectionPool
17. *@author武汉软件工程职业学院<br>
18. *孟德军<br>
19. *2009-01-01<br>
20. *封装了Dbutils工具<br>
21. *的部分细节
22. *@version2.0
23. */
24. publicinterfaceDmDataSourceextendsDataSource,Serializable{
26. /**
27. *@see#resultset存放数据库的表信息.
28. */
29. ResultSetresultset=null;
30. /**
31. *@see#con数据库连接
32. */
33. Connectioncon=null;
34. /**
35. *@see#pool连接池容器.可自行选择。
36. */
37. Vector<Connection>pool=null;
38. /**
39. *@see#driverclass数据库驱动类
40. */
41. Stringdriverclass=null;
42. /**
43. *@see#uername数据库用户名
44. */
45. Stringuername=null;
46. /**
47. *@see#password数据库密码
48. */
49. Stringpassword=null;
50. /**
51. *@see#url连接数据库url
52. */
53. Stringurl=null;
54. /**
55. *@see#filepath配置文件路径.
56. */
57. Stringfilepath=null;
58. /**
59. *@see#logpath日志文件路径.
60. */
61. Stringlogpath=null;
62. /**
63. *@see#maxwaittime允许等待时间
64. */
65. intmaxwaittime=0;
66. /**
67. *@see#delaytime延迟时间
68. */
69. intdelaytime=0;
70. /**
71. *@see#maxconnection最大连接
72. */
73. intmaxconnection=0;
74. /**
75. *@see#minconnection最小连接
76. */
77. intminconnection=0;
78. /**
79. *@see#poolsize连接池大小.
80. */
81. intpoolsize=0;
83. publicvoidcloseConnectionPool()throwsSQLException;
84. /**
85. *@paramusername数据库用户名<br>password数据库密码
86. *@deprecated建议使用getconnection()
87. *@see#getConnection()参见
88. */
89. publicConnectiongetConnection(Stringusername,Stringpassword)
90. throwsSQLException;
91. /**
92. *@see#getConnection()无用户名和密码，以在配置文件中配置。
93. */
94. publicConnectiongetConnection()throwsSQLException;
96. publicPrintWritergetLogWriter()throwsSQLException;
98. publicintgetLoginTimeout()throwsSQLException;
100. publicvoidreleaseConnection(Connectioncon);
102. publicvoidsetLogWriter(PrintWriterout)throwsSQLException;
104. publicvoidsetLoginTimeout(intseconds)throwsSQLException;
106. publicMapmapexecuteQuery(Stringsql)throwsSQLException;
108. publicListlistexecuteQuery(Stringsql,Classbeanclass)
109. throwsSQLException;
111. publicResultSetgetTables(Stringcatalog,Stringschemapattern,
112. Stringtablenamepattern,String[]types)throwsSQLException;
114. publicintgetJDBCMajorVersion()throwsSQLException;
116. publicintgeneralUpdate(Stringsql)throwsSQLException;
118. publicResultSetgeneralQuery(Stringsql)throwsSQLException;
120. publicStringtoChinese(Stringstr,StringoldcharsetName,
121. StringnewcharsetName)throwsUnsupportedEncodingException;
122. }

1. packagecom.mdj.dmdatabase.DmDriverManager;
3. importjava.io.File;
4. importjava.io.FileInputStream;
5. importjava.io.FileNotFoundException;
6. importjava.io.FileWriter;
7. importjava.io.IOException;
8. importjava.io.InputStream;
9. importjava.io.PrintWriter;
10. importjava.io.UnsupportedEncodingException;
11. importjava.sql.Connection;
12. importjava.sql.DatabaseMetaData;
13. importjava.sql.DriverManager;
14. importjava.sql.PreparedStatement;
15. importjava.sql.ResultSet;
16. importjava.sql.SQLException;
17. importjava.sql.Statement;
18. importjava.util.Date;
19. importjava.util.List;
20. importjava.util.Map;
21. importjava.util.Properties;
22. importjava.util.Timer;
23. importjava.util.TimerTask;
24. importjava.util.Vector;
26. importjavax.xml.parsers.DocumentBuilder;
27. importjavax.xml.parsers.DocumentBuilderFactory;
28. importjavax.xml.parsers.ParserConfigurationException;
30. importorg.apache.commons.dbutils.DbUtils;
31. importorg.apache.commons.dbutils.QueryRunner;
32. importorg.apache.commons.dbutils.handlers.BeanListHandler;
33. importorg.apache.commons.dbutils.handlers.MapListHandler;
34. importorg.w3c.dom.Document;
35. importorg.w3c.dom.Element;
36. importorg.w3c.dom.NodeList;
37. importorg.xml.sax.SAXException;
39. importcom.mdj.dmdatabase.pool.Dmconnection;
41. /**
42. *@seeConnectionpoolEasyconnectionPool
43. *@author<hr><pbgcolor="#9acd32">武汉软件工程职业学院</p>
44. *孟德军<br>
45. *2009-01-03<br>
46. *封装了Dbutils<br>
47. *工具的部分细节
48. *
49. *@version2.0
50. */
51. publicclassDatabaseManagerextendsDmconnection{
53. /**
54. *
55. */
56. privatestaticfinallongserialVersionUID=1L;
57. /**
58. *@see#databasemetaData数据源.
59. */
60. privateDatabaseMetaDatadatabasemetaData;
61. /**
62. *@see#resultset存放数据库的表信息.
63. */
64. privateResultSetresultset=null;
65. /**
66. *@see#map存放mapexecuteQuery查询结果
67. */
68. privateMapmap=null;
69. /**
70. *@see#list存放listexecuteQuery查询结果
71. */
72. privateListlist=null;
73. /**
74. *@see#con数据库连接
75. */
76. privateConnectioncon=null;
77. /**
78. *@see#pool连接池容器.可自行选择。
79. */
80. privateVector<Connection>pool=null;
81. /**
82. *@see#driverclass数据库驱动类
83. */
84. privateStringdriverclass="dm.jdbc.driver.DmDriver";
85. /**
86. *@see#uername数据库用户名
87. */
88. privateStringusername="SYSDBA";
89. /**
90. *@see#password数据库密码
91. */
92. privateStringpassword="123456";
93. /**
94. *@see#url连接数据库url
95. */
96. privateStringurl="jdbc:dm://localhost:12345/guest";
97. /**
98. *@see#filepath配置文件路径.
99. */
100. privatestaticStringfilepath=null;
101. /**
102. *@see#logpath日志文件路径.
103. */
104. privateStringlogpath="..//server.log";
105. /**
106. *@see#maxwaittime允许等待时间
107. */
108. privateintmaxwaittime=10;
109. /**
110. *@see#delaytime延迟时间
111. */
112. privateintdelaytime=10;
113. /**
114. *@see#maxconnection最大连接
115. */
116. privateintmaxconnection=10;
117. /**
118. *@see#minconnection最小连接
119. */
120. privateintminconnection=5;
121. /**
122. *@see#poolsize连接池大小.
123. */
124. privateintpoolsize=10;
125. /**
126. *@see#manager本类实例.
127. */
128. privatestaticDatabaseManagermanager=null;
129. /**
130. *@see#timer扫描连接池.
131. */
132. privateTimertimer;
133. privatePrintWriterwriter;
134. privatebooleanloading=false;
136. /**
137. *@see#addConnection()为连接池添加连接
138. *@throwsClassNotFoundException
139. */
140. privateDatabaseManager(){
141. try{
142. init();
143. Filefile=newFile(logpath);
144. writer=newPrintWriter(newFileWriter(file.getAbsolutePath(),
145. true),true);
146. addConnection();
147. }catch(IOExceptione){
148. e.printStackTrace();
149. }
151. }
153. privatevoidinit(){
154. if(loading==false){
155. config(filepath);
156. }else{
158. readconfig(filepath);
159. }
160. pool=newVector<Connection>(maxconnection);
161. timer=newTimer(true);
162. }
164. staticpublicsynchronizedDatabaseManagergetinstance(Stringpath){
165. //必须先初始化变量filepath,然后在创建变量.
166. DatabaseManager.filepath=path;
167. if(manager==null){
168. manager=newDatabaseManager();
169. }
170. returnmanager;
171. }
173. privatevoidaddConnection(){
174. serverlog("serverstart");
175. for(inti=0;i<maxconnection;i++){
176. try{
177. Class.forName(driverclass);
178. DriverManager.setLogWriter(writer);
179. DriverManager.setLoginTimeout(maxwaittime);
180. con=DriverManager.getConnection(url,username,password);
181. pool.add(con);
183. }catch(ClassNotFoundExceptione){
184. //TODOAuto-generatedcatchblock
185. serverlog(e.getMessage());
186. }catch(SQLExceptione){
187. //TODOAuto-generatedcatchblock
188. serverlog(e.getMessage());
189. }
190. }
191. }
193. /**
194. *@see#releaseConnection(Connection)释放连接，返还连接池.
195. *@returncon当前连接.
196. *
197. */
198. publicsynchronizedConnectiongetConnection()throwsSQLException{
199. if(pool.size()>0){
200. con=pool.get(0);
201. pool.remove(0);
202. scaner();
203. returncon;
204. }else{
205. returncon;
206. }
208. }
210. /**
211. *@see#releaseConnection(Connection)释放连接，返还连接池.
212. *@returncon当前连接.
213. *
214. */
215. publicsynchronizedConnectiongetConnection(Stringusername,
216. Stringpassword){
217. if(pool.size()>0){
218. con=pool.get(0);
219. pool.remove(0);
220. returncon;
221. }else{
222. returncon;
223. }
225. }
227. publicsynchronizedvoidreleaseConnection(Connectioncon){
228. pool.add(con);
230. }
232. /**
233. *@return无返回值
234. *@see#closeConnectionPool()关闭连接，清空连接池.
235. *@throwsSQLException
236. */
237. publicvoidcloseConnectionPool()throwsSQLException{
238. for(inti=0;i<pool.size();i++){
239. pool.get(i).close();
240. pool.clear();
241. timer.cancel();
242. }
243. }
245. /**
246. *@see#scaner()扫描连接池.
247. */
248. privatevoidscaner(){
249. TimerTasktask=newTimerTask(){
250. @Override
251. publicvoidrun(){
252. //TODOAuto-generatedmethodstub
253. if(manager.pool.size()<maxconnection){
254. while(manager.pool.size()<maxconnection){
255. addConnection();
256. }
257. }
258. }
260. };
261. timer.schedule(task,10000,10000);
262. }
264. /**
265. *@see#config(String)读取配置文件.<br>
266. *初始化数据库连接数据.
267. *@since<hr>http://blog.csdn.net/mak0000<a
268. *href="http://blog.csdn.net/mak0000">更多信息</a>
269. *@throwspath
270. *为配置文件路径，文件路径错误会抛出FileNotFoundException异常
271. */
272. /**
273. *@see#config(String)读取配置文件.
274. */
275. privatevoidconfig(Stringpath){
276. loading=true;
277. DocumentBuilderFactoryfactory=DocumentBuilderFactory.newInstance();
278. try{
279. DocumentBuilderbuilder=factory.newDocumentBuilder();
280. Documentdocument=builder.parse(DatabaseManager.filepath);
281. NodeListnodelist=document.getElementsByTagName("dbmsdriver");
282. for(inti=0;i<nodelist.getLength();i++){
283. Elementelement=(Element)nodelist.item(i);
284. driverclass=element.getElementsByTagName("driverclass").item(
285. 0).getFirstChild().getNodeValue();
286. url=element.getElementsByTagName("url").item(0)
287. .getFirstChild().getNodeValue();
288. username=element.getElementsByTagName("username").item(0)
289. .getFirstChild().getNodeValue();
290. password=element.getElementsByTagName("password").item(0)
291. .getFirstChild().getNodeValue();
292. maxconnection=Integer
293. .parseInt(element.getElementsByTagName("maxconnection")
294. .item(0).getFirstChild().getNodeValue());
295. minconnection=Integer
296. .parseInt(element.getElementsByTagName("minconnection")
297. .item(0).getFirstChild().getNodeValue());
298. logpath=element.getElementsByTagName("logpath").item(0)
299. .getFirstChild().getNodeValue();
300. maxwaittime=Integer.parseInt(element.getElementsByTagName(
301. "maxwaittime").item(0).getFirstChild().getNodeValue());
302. delaytime=Integer.parseInt(element.getElementsByTagName(
303. "delaytime").item(0).getFirstChild().getNodeValue());
304. }
305. }catch(ParserConfigurationExceptione){
306. //TODOAuto-generatedcatchblock
307. e.printStackTrace();
308. serverlog(newDate()+":/t"+e.getMessage()+"/n");
309. }catch(SAXExceptione){
310. e.printStackTrace();
311. serverlog(newDate()+":/t"+e.getMessage()+"/n");
312. }catch(IOExceptione){
313. e.printStackTrace();
314. serverlog(newDate()+":/t"+e.getMessage()+"/n");
315. }
316. }
318. /**
319. *@deprecated该方法为候选方法.
320. *@parampath
321. *配置文件路径.
322. */
323. publicvoidreadconfig(Stringpath){
324. loading=false;
325. Propertiesproperties=newProperties();
326. try{
327. InputStreamin=newFileInputStream(DatabaseManager.filepath);
328. properties.load(in);
329. driverclass=properties.getProperty("driverclass");
330. url=properties.getProperty("url");
331. username=properties.getProperty("username");
332. password=properties.getProperty("password");
333. maxconnection=Integer.parseInt(properties
334. .getProperty("maxconnection"));
335. minconnection=Integer.parseInt(properties
336. .getProperty("minconnection"));
337. delaytime=Integer.parseInt(properties.getProperty("delaytime"));
338. logpath=properties.getProperty("logpath");
339. in.close();
340. }catch(FileNotFoundExceptione){
342. e.printStackTrace();
343. }catch(IOExceptione){
345. e.printStackTrace();
346. }
347. }
349. /**
350. *@see#serverlog(String)日志.
351. *@parammsg
352. *异常及日常信息.
353. *@since<ahref="http://www.w3.org/xmlschema">建议将变量以配置文件形式存放，<br>
354. *以方便使用,例如xml,properties<br>
355. *文件.</a>
356. */
358. privatevoidserverlog(Stringmsg){
359. writer.println(newDate()+":"+msg);
360. writer.close();
361. }
363. /**
364. *@see#setLogWriter(PrintWriter)setdelaytime
365. *@throwsSQLException
366. */
367. publicvoidsetLoginTimeout(intseconds)throwsSQLException{
368. this.maxwaittime=seconds;
369. }
371. /**
372. *@see#getLoginTimeout()getdelaytime.
373. *@throwsSQLException
374. */
375. publicintgetLoginTimeout()throwsSQLException{
376. returnmaxwaittime;
377. }
379. /**
380. *@see#setLogWriter(PrintWriter)setlogwriter.
381. *@throwsSQLException
382. */
384. publicvoidsetLogWriter(PrintWriterout)throwsSQLException{
385. this.writer=out;
386. }
388. /**
389. *@see#getLogWriter()getlogwriter
390. *@throwsSQLException
391. */
392. publicPrintWritergetLogWriter()throwsSQLException{
393. returnwriter;
394. }
396. /**
397. *@see#listexecuteQuery(String,Class)putthevarinlist,listincludesobjectsbean
398. *@sinceBook.class<br>
399. *Bookbook=(Book)result.get(i);<br>
400. *book.getid();
401. */
402. @Override
403. publicListlistexecuteQuery(Stringsql,Classbeanclass)
404. throwsSQLException{
405. con=getConnection();
406. DbUtils.loadDriver(driverclass);
407. //buildaqueryrunnerinstance.
408. QueryRunnerqueryrunner=newQueryRunner();
409. list=(List)queryrunner.query(con,sql,
410. newBeanListHandler(beanclass));
411. releaseConnection(con);
412. returnlist;
414. }
416. /**
417. *@see#mapexecuteQuery(String)map形式存放数据.listincludesmap
418. */
419. @Override
420. publicMapmapexecuteQuery(Stringsql)throwsSQLException{
421. //TODOAuto-generatedmethodstub
422. con=getConnection();
423. DbUtils.loadDriver(driverclass);
424. QueryRunnerqueryrunner=newQueryRunner();
425. list=(List)queryrunner.query(con,sql,newMapListHandler());
426. releaseConnection(con);
427. for(inti=0;i<list.size();i++){
428. map=(Map)list.get(i);
429. }
430. returnmap;
431. }
433. /**
434. *@see#getTables(String,String,String,String[])获取数据库表结构.
435. *@paramcatalog
436. *,schemaPattern,tableNamePattern,types
437. *
438. */
439. publicResultSetgetTables(Stringcatalog,StringschemaPattern,
440. StringtableNamePattern,String[]types)throwsSQLException{
441. con=getConnection();
442. databasemetaData=con.getMetaData();
443. resultset=databasemetaData.getTables(catalog,schemaPattern,
444. tableNamePattern,types);
445. releaseConnection(con);
446. returnresultset;
447. }
449. /**
450. *@see#getJDBCMajorVersion()jdbc主版本号.
451. */
452. @Override
453. publicintgetJDBCMajorVersion()throwsSQLException{
454. //TODOAuto-generatedmethodstub
455. con=getConnection();
456. databasemetaData=con.getMetaData();
457. intversion=databasemetaData.getJDBCMajorVersion();
458. releaseConnection(con);
459. returnversion;
460. }
462. /**
463. *@see#getJDBCMinorVersion()jdbc次版本号.
464. */
465. @Override
466. publicintgetJDBCMinorVersion()throwsSQLException{
467. //TODOAuto-generatedmethodstub
468. con=getConnection();
469. databasemetaData=con.getMetaData();
470. intversion=databasemetaData.getJDBCMinorVersion();
471. releaseConnection(con);
472. returnversion;
473. }
475. @Override
476. /*
477. *@see#getMaxConnections()数据库支持的同时建立连接的对象数目.
478. */
479. publicintgetMaxConnections()throwsSQLException{
481. con=getConnection();
482. databasemetaData=con.getMetaData();
483. intmaxconnection=databasemetaData.getMaxConnections();
484. releaseConnection(con);
485. returnmaxconnection;
486. }
488. /**
489. *@see#getMaxStatements()数据库支持同时打开statement的数目.
490. */
491. @Override
492. publicintgetMaxStatements()throwsSQLException{
493. //TODOAuto-generatedmethodstub
494. con=getConnection();
495. databasemetaData=con.getMetaData();
496. intminconnection=databasemetaData.getMaxStatements();
497. releaseConnection(con);
498. returnminconnection;
499. }
501. /**
502. *@see#generalUpdate(String)更新.
503. */
504. publicintgeneralUpdate(Stringsql){
505. intresult=0;
506. Statementstatement;
507. try{
508. con=getConnection();
509. statement=con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
510. ResultSet.CONCUR_UPDATABLE);
511. result=statement.executeUpdate(sql);
512. statement.close();
513. releaseConnection(con);
514. }catch(SQLExceptione){
515. //TODOAuto-generatedcatchblock
516. serverlog(e.getSQLState()+"/t"+e.getMessage());
517. }
519. returnresult;
521. }
523. publicResultSetgeneralQuery(Stringsql){
524. ResultSetresult=null;
526. Statementstatement;
527. try{
528. con=getConnection();
529. statement=con.createStatement();
530. result=statement.executeQuery(sql);
531. result.close();
532. statement.close();
533. releaseConnection(con);
534. }catch(SQLExceptione){
535. serverlog(e.getSQLState()+"/t"+e.getMessage());
536. }
537. returnresult;
538. }
540. publicStringtoChinese(Stringstr,StringoldcharsetName,
541. StringnewcharsetName){
542. Stringchinesestr=null;
543. if(str.equals(null)||str==""){
544. chinesestr="";
545. }else{
546. try{
547. chinesestr=newString(str.getBytes(oldcharsetName),
548. newcharsetName);
549. }catch(UnsupportedEncodingExceptione){
550. serverlog("/t"+e.getMessage());
551. }
552. }
553. returnchinesestr;
554. }
556. }

1. packagecom.mdj.dmdatabase.test;
3. importjava.io.IOException;
4. importjava.sql.Connection;
5. importjava.sql.SQLException;
6. importjava.util.List;
7. importjava.util.Map;
9. importcom.mdj.dmdatabase.DmDriverManager.DatabaseManager;
10. importcom.mdj.dmdatabase.javabean.Guest;
12. /**
13. *@since<ahref="http://blog.csdn.net/mak0000">Connectionpool
14. *EasyconnectionPool</a>
15. *@author武汉软件工程职业学院<br>
16. *孟德军<br>
17. *2009-01-01<br>
18. *封装了Dbutils工具<br>
19. *的部分细节
20. *@version2.0
21. *
22. */
23. publicclassTest{
24. /**
25. *@see#managerDatabaseManager类的实例.
26. */
27. privateDatabaseManagermanager;
28. /**
29. *@see#con<pbgcolor="#9acd32">java.sql.ConnectionconConnection实例</p>
30. */
31. privateConnectioncon=null;
33. publicTest(Stringpath)throwsIOException,SQLException{
36. manager=DatabaseManager.getinstance(path);
37. //con=manager.getConnection();
38. /**
39. *此处书写代码.查询数据无需用connection接收
40. */
41. /*inta=manager.generalUpdate("insertintoguestbook(author,title,ip,updatetime,content)values('王红梅','你过得怎么样','192.168.18.1','2009-01-04','你过得怎么样')");
42. System.out.println(a);*/
43. Mapmap=manager.mapexecuteQuery("select*fromguestbook");
44. for(inti=0;i<map.size();i++){
45. System.out.println(map.get("author")+""+map.get("title")+""
46. +map.get("ip")+map.get("updatetime")+""
47. +map.get("content"));
48. }
49. Listlist=manager.listexecuteQuery("select*fromguestbook",
50. Guest.class);
51. Guestguestbook=null;
52. for(inti=0;i<list.size();i++){
53. guestbook=(Guest)list.get(i);
54. System.out
55. .println(guestbook.getAuthor()+"/t"
56. +guestbook.getTitle()+"/t"+guestbook.getIp()
57. +"/t"+guestbook.getUpdatetime()+"/t"
58. +guestbook.getContent());
59. }
62. manager.releaseConnection(con);manager.closeConnectionPool();
65. }
67. publicstaticvoidmain(String[]args){
69. Stringpath=System.getProperty("user.dir")+"//src//sysconfig.xml";
70. try{
71. newTest(path);
72. }catch(SQLExceptione){
74. }catch(IOExceptione){
75. e.printStackTrace();
76. }
77. }
79. }