pymysql连接数据库

一、pymysql的相关参数及方法

1.pymysql.connect()参数说明：（连接数据库时需要添加的参数）

参数	类型	描述
host	str	MySQL服务器地址，IP地址或域名
port	int	MySQL服务器端口号
user	str	用户名
passwd	str	密码
db	str	数据库名称
charset	str	连接编码

2.connect()对象支持的方法

方法	描述
cursor()	使用该连接创建并返回游标
commit()	提交当前事务
rollback()	回滚当前事务
close()	关闭连接

3.cursor（）支持的方法

excute()：执行一个数据库的查询命令

excutemany()：重复执行一个sql命令

fetchall()：接收全部的返回结果

fetchone()：接收一条结果

fetchmany()：获取size行结果

rowcount()：返回数据条数

close()：关闭游标对象

二、案例

import pymysql

config={
    'host':'127.0.0.1',
    'port':3306,
    'user':'root',
    'passwd':'root',
}

#连接数据库
conn=pymysql.connect(**config)
conn.autocommit(1)

#获取游标对象
cursor=conn.cursor()

try:
    #创建数据库
    DB_NAME='test1'
    cursor.execute('drop database if exists %s' %DB_NAME)
    cursor.execute('create database if not exists %s'%DB_NAME)
    conn.select_db(DB_NAME)

    #创建表
    TABLE_NAME='user'
    cursor.execute('create table %s(id int primary key,name varchar(30))'%TABLE_NAME)

    #批量插入数据
    values=[]
    for i in range(20):
        values.append((i,"kk"+str(i)))
    cursor.executemany('insert into user values(%s,%s)',values)

    #查询数据条目
    count=cursor.execute('select * from %s'%TABLE_NAME)
    print('total records:',cursor.rowcount)

    #获取表名信息
    desc=cursor.description
    print("%s,%3s"%(desc[0][0],desc[1][0]))
    cursor.scroll(10,mode='absolute')
    results=cursor.fetchall()
    print("test")
    for result in results:
        print(result)

except:
    import traceback
    traceback.print_exc()
    conn.rollback()
finally:
    cursor.close()