参见附件:
1、DataConnector
package com.yuanzheng.database; import java.sql.Connection; import java.sql.SQLException; import org.apache.commons.dbcp.cpdsadapter.DriverAdapterCPDS; import org.apache.commons.dbcp.datasources.SharedPoolDataSource; public class DataConnector { public static SharedPoolDataSource sharedDatasource; public DataConnector() { DriverAdapterCPDS myConnectionPoolDatasource=new DriverAdapterCPDS(); try { myConnectionPoolDatasource.setDriver(DataConstants.driver); }catch(Exception e) { e.printStackTrace(); } myConnectionPoolDatasource.setUrl(DataConstants.jdbc_url); myConnectionPoolDatasource.setUser(DataConstants.database_name); myConnectionPoolDatasource.setPassword(DataConstants.database_pwd); sharedDatasource=new SharedPoolDataSource(); sharedDatasource.setConnectionPoolDataSource(myConnectionPoolDatasource); sharedDatasource.setMaxActive(30); sharedDatasource.setMaxWait(30); } public Connection getConnection() throws SQLException { return sharedDatasource.getConnection(); } }
2、DataConstants
package com.yuanzheng.database; public abstract class DataConstants { public static final String driver="com.mysql.jdbc.Driver"; public static final String database_name="root"; public static final String database_pwd="root"; public static final String jdbc_url="jdbc:mysql://localhost:3306/yuanzheng"; }