import pymysql

1、pip install pymysql

 

 

 2、連接數據庫，並創建表，插入數據

import pymysql
# 1. 連接數據庫，
db = pymysql.connect("localhost", "root", "1234abcd", "test")
# ****python, 必須有一個游標對象， 用來給數據庫發送sql語句， 並執行的.
# 2. 創建游標對象，
cur = db.cursor()
# 3. 對於數據庫進行增刪改查
# 1). ************************創建數據表**********************************
try:
    create_sqli = "create table hello (id int, name varchar(50));"
# 執行創建表
    cur.execute(create_sqli)
# try后面的執行失敗，給出提示
except Exception as e:
    print("創建數據表失敗:", e)
# try后面執行成功，給出提示
else:
    print("創建數據表成功;")
## 2). *********************插入數據****************************
try:
    insert_sqli = "insert into hello values(2, 'fensi');"
    cur.execute(insert_sqli)
except Exception as e:
    print("插入數據失敗:", e)
else:
    # 如果是插入數據， 一定要提交數據， 不然數據庫中找不到要插入的數據;
    db.commit()
    print("插入數據成功;")
# 4. 關閉游標
cur.close()
# 5. 關閉連接
db.close()

運行結果：

 

 

3、插入多條數據

import pymysql
# 1. 連接數據庫，
db = pymysql.connect("localhost", "root", "1234abcd", "test")
# ****python, 必須有一個游標對象， 用來給數據庫發送sql語句， 並執行的.
# 2. 創建游標對象，
cur = db.cursor()
 
# 1). ************************創建數據表**********************************
try:
    create_sqli = "create table hello (id int, name varchar(50));"
# 執行創建表
    cur.execute(create_sqli)
# try后面的執行失敗，給出提示
except Exception as e:
    print("創建數據表失敗:", e)
# try后面執行成功，給出提示
else:
    print("創建數據表成功;")

# 插入多條數據

try:
    info = [(i, "westos%s" %(i)) for i in range(100)]
    insert_sqli = "insert into hello values(%s, %s);"
    cur.executemany(insert_sqli, info )
except Exception as e:
    print("插入多條數據失敗:", e)
else:
    # 如果是插入數據， 一定要提交數據， 不然數據庫中找不到要插入的數據;
    db.commit()
    print("插入多條數據成功;")

#  **************************數據庫查詢*****************************
sqli = "select * from hello;"
result = cur.execute(sqli)  # 默認不返回查詢結果集， 返回數據記錄數。
print(result)
print(cur.fetchone())     # 1). 獲取下一個查詢結果集;
print(cur.fetchone())
print(cur.fetchone())
print(cur.fetchmany(4))   # 2). 獲取制定個數個查詢結果集；
info = cur.fetchall()     # 3). 獲取所有的查詢結果
print(info)
print(len(info))
print(cur.rowcount)       # 4). 返回執行sql語句影響的行數
#  5). 移動游標指針
print(cur.fetchmany(3))
print("正在移動指針到最開始......")
cur.scroll(0, 'absolute')
print(cur.fetchmany(3))
print("正在移動指針到倒數第2個......")
print(cur.fetchall())    # 移動到最后
cur.scroll(-2, mode='relative')
print(cur.fetchall())
# 4. 關閉游標
cur.close()
# 5. 關閉連接
db.close()