mysql连接池实例,mysql连接池实现

本文目录一览：

1、MySQL与Redis数据库连接池介绍（图示+源码+代码演示）
2、mysql的数据连接池怎么配置文件
3、如何实现python的mysql连接池并加入缓存过期

MySQL与Redis数据库连接池介绍（图示+源码+代码演示）

数据库连接池（Connection pooling）是程序启动时建立足够的数据库连接，并将这些连接组成一个连接池，由程序动态地对池中的连接进行申请，使用，释放。

简单的说：创建数据库连接是一个很耗时的操作，也容易对数据库造成安全隐患。所以，在程序初始化的时候，集中创建多个数据库连接，并把他们集中管理，供程序使用，可以保证较快的数据库读写速度，还更加安全可靠。

不使用数据库连接池

如果不使用数据库连接池，对于每一次SQL操作，都要走一遍下面完整的流程：

1.TCP建立连接的三次握手（客户端与 MySQL服务器的连接基于TCP协议）

2.MySQL认证的三次我收

3.真正的SQL执行

4.MySQL的关闭

5.TCP的四次握手关闭

可以看出来，为了执行一条SQL，需要进行大量的初始化与关闭操作

使用数据库连接池

如果使用数据库连接池，那么会事先申请（初始化）好相关的数据库连接，然后在之后的SQL操作中会复用这些数据库连接，操作结束之后数据库也不会断开连接，而是将数据库对象放回到数据库连接池中

资源重用：由于数据库连接得到重用，避免了频繁的创建、释放连接引起的性能开销，在减少系统消耗的基础上，另一方面也增进了系统运行环境的平稳性（减少内存碎片以及数据库临时进程/线程的数量）。

更快的系统响应速度：数据库连接池在初始化过程中，往往已经创建了若干数据库连接置于池中备用。此时连接的初始化工作均已完成。对于业务请求处理而言，直接利用现有可用连接，避免了从数据库连接初始化和释放过程的开销，从而缩减了系统整体响应时间。

统一的连接管理，避免数据库连接泄露：在较为完备的数据库连接池实现中，可根据预先的连接占用超时设定，强制收回被占用连接。从而避免了常规数据库连接操作中可能出现的资源泄露。

如果说你的服务器CPU是4核i7的，连接池大小应该为((4*2)+1)=9

mysql的数据连接池怎么配置文件

连接先建立一些连接，并且这些连接允许共享，因此这样就节省了每次连接的时间开销。Mysql数据库为例，连接池在Tomcat中的配置与使用。

1、创建数据库Student,表student

2、配置server.xml文件。Tomcat安装目录下conf中server.xml文件。

GlobalNamingResources

Resource

name=”jdbc/DBPool”

type=”javax.sql.DataSource”

password=””

driverClassName=”com.mysql.jdbc.Driver”

maxIdle=”2″

maxWait=”5000″

username=”root”

url=”jdbc:mysql://localhost:3306/student”

maxActive=”3″

/GlobalNamingResources

name:指定连接池的名称

type:指定连接池的类，他负责连接池的事务处理

url:指定要连接的数据库

driverClassName:指定连接数据库使用的驱动程序

username:数据库用户名

password:数据库密码

maxWait:指定最大建立连接等待时间，如果超过此时间将接到异常

maxIdle:指定连接池中连接的最大空闲数

maxActive:指定连接池最大连接数

3、配置web.xml文件。

web-app

resource-ref

descriptionmysql数据库连接池配置/description

res-ref-namejdbc/DBPool/res-ref-name

res-typejavax.sql.DataSource/res-type

res-authContainer/res-auth

res-sharing-scopeShareable/res-sharing-scope

/resource-ref

/web-app

4、配置context.xml文件

与server.xml文件所在的位置相同。

Context

ResourceLink

name=”jdbc/DBPool”

type=”javax.sql.DataSource”

global=”jdbc/DBPool”

/Context

5、测试

DataSource pool = null;

Context env = null;

Connection conn = null;

Statement st = null;

ResultSet rs = null;

try{

env = (Context)new InitialContext().lookup(“java:comp/env”);

//检索指定的对象，返回此上下文的一个新实例

pool = (DataSource)env.lookup(“jdbc/DBPool”);

//获得数据库连接池

if(pool==null){out.printl(“找不到指定的连接池！”);}

con = pool.getConnection();

st = con.createStatement();

rs = st.executeQuery(“select * from student”);

}catch(Exception ex){out.printl(ne.toString());}

如何实现python的mysql连接池并加入缓存过期

import MySQLdb

import time

import string

import redis

class PooledConnection:

#构建连接池实例

def __init__(self, maxconnections, connstr,dbtype):

from Queue import Queue

self._pool = Queue(maxconnections) # create the queue

self.connstr = connstr

self.dbtype=dbtype

self.maxconnections=maxconnections

#根据你给数目来创建链接，并且写入刚才创建的队列里面。

try:

for i in range(maxconnections):

self.fillConnection(self.CreateConnection(connstr,dbtype))

except Exception,e:

raise e

def fillConnection(self,conn):

try:

self._pool.put(conn)

except Exception,e:

raise “fillConnection error:”+str(e)

def returnConnection(self, conn):

try:

self._pool.put(conn)

except Exception,e:

raise “returnConnection error:”+str(e)

def getConnection(self):

try:

return self._pool.get()

except Exception,e:

raise “getConnection error:”+str(e)

def ColseConnection(self,conn):

try:

self._pool.get().close()

self.fillConnection(self.CreateConnection(connstr,dbtype))

except Exception,e:

raise “CloseConnection error:”+str(e)

def CreateConnection(self,connstr,dbtype):

if dbtype==’xxx’:

pass

elif dbtype==’mysql’:

try:

db_conn = connstr.split(“#”);

#conndb=MySQLdb.connect(db=conf.mydb,host=conf.dbip,user=conf.myuser,passwd=conf.mypasswd);

conndb=MySQLdb.connect(user=db_conn[0],passwd=db_conn[1],host=db_conn[2],port=string.atoi(db_conn[3]),db=db_conn[4]);

conndb.clientinfo = ‘datasync connection pool from datasync.py’;

conndb.ping();

except Exception, e:

raise ‘conn targetdb datasource Excepts,%s!!!(%s).’%(db_conn[2],str(e))

return None

#mysql如下创建连接池：

connstring=”xiaorui.cc#xiaoru.cc#xiaorui.cc#3306#dbname”;

mysqlpool=PooledConnection(10,connstring,”mysql”);

#获取连接:

mysqlpool.getConnection()

原创文章，作者：小蓝，如若转载，请注明出处：https://www.506064.com/n/219954.html

mysql连接池实例,mysql连接池实现

本文目录一览：

MySQL与Redis数据库连接池介绍（图示+源码+代码演示）

mysql的数据连接池怎么配置文件

如何实现python的mysql连接池并加入缓存过期

相关推荐

发表回复