首先，我們需要一個可池化對象，這裡我選用了com.funtester.db.mysql.FunMySql，這是我自己寫的單連結的MySQL物件。我計劃用這個作為基礎可池化物件。
package com.funtester.db.mysql; import com.funtester.base.interfaces.IMySqlBasic; import com.funtester.config.SqlConstant; import java.sql.Connection; import java.sql.ResultSet; import java.sql.Statement; /** * mysql操作的基础类 *用于存储数据，多用于爬虫
*/ public class FunMySql extends SqlBase implements IMySqlBasic { /** * {@link SqlConstant#FUN_SQL_URL}会替换IP到URL */ String url; /** * 库 */ String database; /** * 用户 */ String user; /** * 密码 */ String password; Connection connection; Statement statement; /** * 私有构造方法 * * @param url 连接地址,包括端口 * @param database 库 * @param user 用户名 * @param password 密码 */ public FunMySql(String url, String database, String user, String password) { this.url = url; this.database = database; this.user = user; this.password = password; getConnection(database); } /** * 初始化连接 */ @Override public void getConnection() { getConnection(EMPTY); } /** * 执行sql语句，非query语句，并不关闭连接 * * @param sql */ @Override public void executeUpdateSql(String sql) { SqlBase.executeUpdateSql(connection, statement, sql); } /** * 查询功能 * * @param sql * @return */ @Override public ResultSet executeQuerySql(String sql) { return SqlBase.executeQuerySql(connection, statement, sql); } /** * 关闭query连接 */ @Override public void over() { SqlBase.close(connection, statement); } @Override public void getConnection(String database) { if (connection == null) connection = SqlBase.getConnection(SqlConstant.FUN_SQL_URL.replace("ip", url).replace("database", database), user, password); if (statement == null) statement = SqlBase.getStatement(connection); } }
相對連接，建立com.funtester.db.mysql.FunMySql的時候，順便一起初始化MySQL連線。然後再com.funtester.db.mysql.MysqlPool.FunTester#destroyObject的時候再進行連接的回收。
/** * 池化工厂类 */ private class FunTester extends BasePooledObjectFactory{ @Override FunMySql create() throws Exception { return new FunMySql(url, database, user, password) } @Override PooledObject wrap(FunMySql obj) { return new DefaultPooledObject (obj) } @Override void destroyObject(PooledObject p) throws Exception { p.getObject().over() super.destroyObject(p) } }
這裡顯得有些冗餘，後面再使用過程中，我會繼續優化。透過建立一個com.funtester.db.mysql.MysqlPool對象，取得一個com.funtester.db.mysql.FunMySql物件池。
/** * 自定义MySQL连接池对象 */ class MysqlPool extends PoolConstant { private static final Logger logger = LogManager.getLogger(MysqlPool.class); /** * {@link com.funtester.config.SqlConstant#FUN_SQL_URL}会替换IP到URL*/ String url; /** * 库 **/ String database; /** * 用户 **/ String user; /** * 密码 **/ String password; private GenericObjectPool pool MysqlPool(String url, String database, String user, String password) { this.url = url this.database = database this.user = user this.password = password init() } /** * 初始化连接池 * @return */ def init() { GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig(); poolConfig.setMaxTotal(MAX); poolConfig.setMinIdle(MIN_IDLE); poolConfig.setMaxIdle(MAX_IDLE); poolConfig.setMaxWaitMillis(MAX_WAIT_TIME); poolConfig.setMinEvictableIdleTimeMillis(MAX_IDLE_TIME); pool = new GenericObjectPool(new FunTester(), poolConfig); } }
自從學習了Go語言的gorm框架和Redis框架，我發現其實不用把池化相關資訊不用暴露出來，直接封裝原始的API，暴露給使用者使用，這樣用戶就不用關心連接的回收問題了。
/** * 借出对象 * @return */ def borrow() { try { return pool.borrowObject() } catch (e) { logger.warn("获取${JSONObject.class} 失败", e) } finally { new JSONObject() } } /** * 归还对象 * @param funMySql * @return */ def back(FunMySql funMySql) { pool.returnObject(funMySql) } /** * 执行update SQL * @param sql * @return */ def execute(def sql) { def driver = borrow() try { driver.executeUpdateSql(sql) } catch (e) { logger.warn("执行:{}失败", sql) } finally { back(driver) } } /** * 执行查询SQL * @param sql * @return */ def query(def sql) { def driver = borrow() try { return driver.executeQuerySql(sql) } catch (e) { logger.warn("执行:{}失败", sql) } finally { back(driver) } }
以上是MySQL池化自訂實例分析的詳細內容。更多資訊請關注PHP中文網其他相關文章！
