Connection pooling in Scala
source link: https://blog.knoldus.com/connection-pooling-in-scala/
Go to the source link to view the article. You can view the picture content, updated content and better typesetting reading experience. If the link is broken, please click the button below to view the snapshot at that time.
Connection pooling in Scala
Reading Time: 3 minutes
In this blog I am going to describe connection pooling in scala. Before going into the details I want to explain why and when connection pooling should be used.
Why connection pooling ??
For efficient use of database connection we need to care about following two things.
1. Creating a connection is an expensive operation. It is not senseful to create new connection each and every time when database access is required.
2. It is also important to close connection and other database resources.
Connection pooling provide one stop solution of above described issues.
In connection pooling , connection or set of connection objects are created single time ( usually at the start of application) and would be maintained so that the connections can be reused when future requests to the database are required. Connection pools are used to enhance the performance of executing commands on a database.
When use connection pooling
If database access is required more frequently in application then connection pooling must be used.
There are many open source connection pooling library available. I preferred BoneCP library.(In this discussion i am using a postgres database for connection pooling.)
1. add boneCP dependencies in build.sbt
build.sbt
xxxxxxxxxx
name := "sbtprojectwithconnectionpooling"
version := "1.0"
scalaVersion := "2.10.3"
organization := "Knoldus"
libraryDependencies ++= Seq(
"ch.qos.logback" % "logback-classic" % "1.0.13",
"postgresql" % "postgresql" % "9.1-901.jdbc4",
"com.jolbox" % "bonecp" % "0.8.0.RELEASE"
)
2. Create connection pool:
Creation of connection pool requied some configuration parameter:
1. jdbcUrl- Jdbc database connection Url.
Default: None
2. username- Database username.
Default: None
3. password- Database password.
Default: None
4. PartitionCount- In order to reduce lock contention and thus improve performance, each incoming connection request picks off a connection from a pool that has thread-affinity, i.e. pool[threadId % partition_count]. The higher this number, the better your performance will be for the case when you have plenty of short-lived threads. Beyond a certain threshold, maintenence of these pools will start to have a negative effect on performance (and only for the case when connections on a partition start running out).
Default: 1, minimum: 1, recommended: 3-4 (but very app specific)
5. maxConnectionsPerPartition- The number of connections to create per partition. Setting this to 5 with 3 partitions means you will have 15 unique connections to the database. Note that BoneCP will not create all these connections in one go but rather start off with minConnectionsPerPartition and gradually increase connections as required.
6. minConnectionsPerPartition-The number of connections to start off with per partition.
for more configuration information: http://jolbox.com/bonecp/downloads/site/apidocs/com/jolbox/bonecp/BoneCPConfig.html
ConnectionPool.scala
xxxxxxxxxx
import com.jolbox.bonecp.BoneCP
import com.jolbox.bonecp.BoneCPConfig
import org.slf4j.LoggerFactory
import java.sql.Connection
import java.sql.DriverManager</code>
object ConnectionPool {val logger = LoggerFactory.getLogger(this.getClass)
private val connectionPool = {try {Class.forName("org.postgresql.Driver")val config = new BoneCPConfig()
config.setJdbcUrl("jdbc:postgresql://localhost:5432/testdb")config.setUsername("postgres")config.setPassword("postgres")config.setMinConnectionsPerPartition(2)
config.setMaxConnectionsPerPartition(5)
config.setPartitionCount(3)
config.setCloseConnectionWatch(true)// if connection is not closed throw exception
config.setLogStatementsEnabled(true) // for debugging purpose
Some(new BoneCP(config))
} catch {case exception: Exception =>;
logger.warn("Error in creation of connection pool"+exception.printStackTrace())None
}
}
def getConnection: Option[Connection] = {connectionPool match {case Some(connPool) => Some(connPool.getConnection)
case None => None
}
}
}
3. Take connection from connection pool and after use return connection to connection pool by calling close method on connection.(Here close method not closing connection, it return connection to connection pool)
ConnectionPoolTest
xxxxxxxxxx
import java.sql.ResultSet
import org.slf4j.LoggerFactory</code>
object ConnectionPoolTest extends App {
val logger = LoggerFactory.getLogger(this.getClass)
val query = "select * from emp"
ConnectionPool.getConnection match {case Some(connection) =>
try {val statement = connection.createStatement()
val result = statement.executeQuery(query)
val scalaResultSet = new MyResultSet(result) map { r => (r.getString(1), r.getString(2), r.getString(3)) }scalaResultSet foreach println _
} catch {case exception: Exception =>
logger.warn("Error in excuting query" + exception.printStackTrace())} finally {if (!connection.isClosed()) connection.close()
}
case None =>;
println("Not geting connection from connection pooling")}
}
class MyResultSet(rs: ResultSet) extends Iterator[ResultSet] {def hasNext: Boolean = rs.next()
def next(): ResultSet = rs
}
4. Run sbt project:
xxxxxxxxxx
sky@Sky:~/knols_sessions/sbtprojectwithconnectionpooling$ sbt run
Loading /home/sky/scalatool/sbt-0.13/bin/sbt-launch-lib.bash
[info] Loading project definition from /home/sky/knols_sessions/sbtprojectwithconnectionpooling/project
[info] Set current project to sbtprojectwithconnectionpooling (in build file:/home/sky/knols_sessions/sbtprojectwithconnectionpooling/)
[info] Compiling 1 Scala source to /home/sky/knols_sessions/sbtprojectwithconnectionpooling/target/scala-2.10/classes...
[info] Running com.knol.app.ConnectionPoolTest
15:38:15.956 [run-main] WARN com.jolbox.bonecp.BoneCP - Thread close connection monitoring has been enabled. This will negatively impact on your performance. Only enable this option for debugging purposes!
15:38:16.088 [run-main] DEBUG com.jolbox.bonecp.StatementHandle - select * from emp
(1212,sk,r&d)
(1213,ak,r&d)
(1214,dk,testing)
15:38:16.111 [BoneCP-pool-watch-thread] DEBUG com.jolbox.bonecp.PoolWatchThread - Terminating pool watch thread
15:38:16.111 [BoneCP-pool-watch-thread] DEBUG com.jolbox.bonecp.PoolWatchThread - Terminating pool watch thread
15:38:16.112 [BoneCP-pool-watch-thread] DEBUG com.jolbox.bonecp.PoolWatchThread - Terminating pool watch thread
15:38:16.111 [BoneCP-pool-watch-thread] DEBUG com.jolbox.bonecp.PoolWatchThread - Terminating pool watch thread</code>
Download complete code example from: here
Recommend
About Joyk
Aggregate valuable and interesting links.
Joyk means Joy of geeK