pycharm 增刪改查 mysql數據庫

1、pycharm創建mysql數據表######################################################
import pymysql
# 創建連接
con = pymysql.connect(host="127.0.0.1", user="aa", password="2018", database="aa", port=3306)
# 創建游標對象
cur = con.cursor()
sql = """
create table wzx_test1224(
id int primary key auto_increment,
name varchar(30) not null,
address int(2)
)
"""
try:
# 執行創建表的sql
cur.execute(sql)
print("創建表成功")
except Exception as e:
print(e)
print("創建表失敗")
finally:
# 關閉游標連接
cur.close()
# 關閉數據庫連接
con.close()

 

2、pycharm插入單條mysql數據######################################################
import pymysql
# 創建連接
con = pymysql.connect(host="127.0.0.1", user="aa", password="2018", database="aa", port=3306)
# 創建游標對象
cur = con.cursor()
# 編寫插入數據的sql
sql = "insert into wzx_test1224 (name,address) values (%s, %s)"
try:
# 執行sql
cur.execute(sql, ("小強", 18))
con.commit()
print("插入數據成功")
except Exception as e:
print(e)
con.rollback()
print("插入數據失敗")
finally:
# 關閉游標連接
cur.close()
# 關閉數據庫連接
con.close()

3、pycharm插入多條mysql數據######################################################
import pymysql
# 創建連接
con = pymysql.connect(host="127.0.0.1", user="aa", password="2018", database="aa", port=3306)
# 創建游標對象
cur = con.cursor()
# 編寫插入數據的sql
sql = "insert into wzx_test1224 (name,address) values (%s, %s)"
try:
# 執行sql
cur.executemany(sql, [("小星星", 18),("小二", 19),("小五", 20)])
con.commit()
print("插入數據成功")
except Exception as e:
print(e)
con.rollback()
print("插入數據失敗")
finally:
# 關閉游標連接
cur.close()
# 關閉數據庫連接
con.close()

 

4、pycharm查詢mysql數據######################################################
import pymysql
# 創建連接
con = pymysql.connect(host="127.0.0.1", user="aa", password="2018", database="aa", port=3306)
# 創建游標對象
cur = con.cursor()
# 編寫查詢的sql
sql = "select * from wzx_test1224"
try:
# 執行sql
cur.execute(sql)
# 處理結果集
wzx_test1224 = cur.fetchall()
for student in wzx_test1224:
print(student)
except Exception as e:
print(e)
print("查詢所有數據失敗")

 

5、pycharm修改mysql數據######################################################
import pymysql
# 創建連接
con = pymysql.connect(host="127.0.0.1", user="aa", password="2018", database="aa", port=3306)
# 創建游標對象
cur = con.cursor()
# 編寫修改的sql
sql = 'update wzx_test1224 set name=%s where id=%s'
try:
# 執行sql
cur.execute(sql, ("薛寶釵", 1))
con.commit()
print("修改成功")
except Exception as e:
print(e)
con.rollback()
print("修改失敗")

6、pycharm刪除mysql數據###################################################### 

import pymysql
# 創建連接
con = pymysql.connect(host="127.0.0.1", user="aa", password="2018", database="aa", port=3306)
# 創建游標對象
cur = con.cursor()
# 編寫刪除的sql
sql = 'delete from wzx_test1224 where name=%s'
try:
# 執行sql
cur.execute(sql, ("薛寶釵"))
con.commit()
print("刪除成功")
except Exception as e:
print(e)
con.rollback()
print("刪除失敗")
finally:
# 關閉游標連接
cur.close()
# 關閉數據庫連接
con.close()

7、pycharm構建測試數據存儲到mysql###################################################### 

from faker import Faker
f=Faker(locale='zh_CN') # 為生成數據的文化選項，默認為en_US，只有使用了相關文化，才能生成相對應的隨機信息

import pymysql
# 創建連接
con = pymysql.connect(host="127.0.0.1", user="aa", password="2018", database="aa", port=3306)
# 創建游標對象
cur = con.cursor()
sql = "insert into  wzx_test1224 (name,address) values (%s, %s)"
try:
    for i in range(10):
        cur.executemany(sql, [(f.name(), f.address())])
        con.commit()
        i=i+1
    print("插入數據成功")
except Exception as e:
    print(e)
    con.rollback()
    print("插入數據失敗")
finally:
    cur.close()
    con.close()