pymysql

基础知识

pip install pymyql

import pymysql
#tcp客户端程序
#建立连接，传输数据

conn=pymysql.connect(host='127.0.0.1',user='root',database='demo') #创建连接用correct方法

cur=conn.cursor()  #获取游标，创建连接之后，获取游标

cur.execute('''insert into `user`(`name`,`age`)value('harden',18)''')  #执行sql

conn.commit() #提交事务

非查询性请求的四个步骤 1.创立连接 2.获取游标 3.执行sql 4.提交事务

cur.execute("""insert into `user`(`name`,`age`)values('pets',34)""")#游标关闭之前可以反复使用

1.

with cur: #自动关闭游标
cur.execute('''insert into `user`(`name`,`age`)value('kobe',39)''')

2.

with conn as cur: #自动提交事务,部关闭cur
cur.execute('''insert into `user`(`name`,`age`)value('kobe',39)''')

3.

with conn as cur: #自动提交事务，
with cur: #自动关闭游标
cur.execute('''insert into `user`(`name`,`age`)value('tim',25)''')

4.

from queue import Queue
class ConnectionPool:
def __init__(self,size,*args,**kwargs):
self._pool=Queue(size)
self.args=args
self.kwargs=kwargs
for x in range(size):
self._pool.put(self._connect())

def _connect(self):
return pymysql.connect(*self.args,**self.kwargs)

def close(self,conn):
conn.close()

def get(self):
return self._pool.get()

def return_resource(self,conn):
self._pool.put()