数据库连接池代码,Scala代码库,德仔网

代码语言
代码分类
【Scala】数据库连接池
作者:泺清 / 发布于2015/5/12/ 1342

	package org.dave.common.database

	import java.util.concurrent.ConcurrentHashMap
	import java.util.ResourceBundle
	import com.jolbox.bonecp.{BoneCPConfig, BoneCP}
	import java.sql.Connection
	import org.slf4j.LoggerFactory

	/**
	* 数据库连接池
	* @Anthor David Day
	* @Date 2011-6-23
	*/
	object DatabaseConnectionPool {

	 private val log = LoggerFactory.getLogger(DatabaseConnectionPool.getClass)

	 private val pools = new ConcurrentHashMap[String, BoneCP]()

	 private val reader = ResourceBundle.getBundle("connection")

	 /**
	 * 启动数据库
	 * @param databases 数据库列表
	 */
	 def startup(datebases : Array[String]) {
	 datebases.foreach(database => {
	 Class.forName(reader.getString(database + ".driver"))
	 val config = new BoneCPConfig
	 config.setJdbcUrl(database + ".url")
	 config.setUsername(database + ".username")
	 config.setPassword(database + ".password")
	 config.setMaxConnectionsPerPartition(Integer.parseInt(database + ".max_connection"))
	 config.setMinConnectionsPerPartition(Integer.parseInt(database + ".min_connection"))
	 config.setPartitionCount(Integer.parseInt(database + ".partition_count"))
	 pools.put(database, new BoneCP(config))
	 log.info("Startup datebase: "+ database)
	 })
	 }

	 /**
	 * 关闭有数据库
	 * @param databases 数据库列表
	 */
	 def shutdown(datebaseNames : Array[String]) {
	 datebaseNames.foreach(name => {
	 pools.get(name).shutdown
	 log.info("Shutdown datebase: "+ name)
	 })
	 }

	 /**
	 * 关闭所有数据库
	 */
	 def shutdownAll {
	 val iter = pools.entrySet.iterator
	 while (iter.hasNext) {
	 val entry = iter.next
	 entry.getValue.shutdown
	 log.info("Shutdown datebase: "+ entry.getKey)
	 }
	 }

	 /**
	 * @param 数据库
	 * @return 数据库连接
	 */
	 def getConnection(database : String) = pools.get(database).getConnection

	 /**
	 * 查询数据库
	 * @param 数据库
	 * @return 数据库连接
	 */
	 def doQuery(database : String) (query : Connection => Unit) {
	 val conn = getConnection(database)
	 try { query(conn) }
	 finally { conn.close }
	 }

	 /**
	 * 更新数据库
	 * @param 数据库
	 * @return 数据库连接
	 */
	 def doUpdate(database : String) (execute : Connection => Unit) {
	 val conn = getConnection(database);
	 try {
	 conn setAutoCommit false
	 execute(conn)
	 conn.commit
	 } catch { case t : Throwable => {
	 conn.rollback
	 throw t
	 } } finally { conn.close }
	 }

	}
试试其它关键字
　数据库连接池　
同语言下
可能有用的
泺清贡献的其它代码(14)