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()