Python操作数据库

# 导入pymysql库
import pymysql
# 创建连接
db_connection = pymysql.connect(
    host='127.0.0.1',
    user='root',
    password='123456',
    database='mysql',
    charset='utf8'
)
# 使用 cursor() 方法创建一个游标对象
cursors = db_connection.cursor()
# 使用 execute()  方法执行 SQL 查询
cursors.execute("SELECT VERSION()")
# 使用 fetchone() 方法获取单条数据.
data = cursors.fetchone()
# 打印数据
print ("Database version : %s " % data)
# 关闭数据库连接
db_connection.close()

# 创建数据库
import pymysql
# 打开数据库连接 
conn = pymysql.connect('localhost', 'root', '123456')
# 使用cursor()方法创建一个游标对象cursor
cursor = conn.cursor()  # 游标对象用于执行查询和获取结果
# 创建数据库 连接数据库时 
sql = 'create database ajie charset utf8;'
# 执行SQL语句
cursor.execute(sql)
# 关闭数据库连接
conn.close()

# 创建数据表
import pymysql
# 打开数据库连接
conn = pymysql.connect('localhost', 'root', '123456', 'ajie')
# 使用cursor()方法创建一个游标对象cursor
cursor = conn.cursor()
# 使用预处理语句创建表
sql = 'create table t1(name char(255), height int, age int,sex char(255))'
# 执行SQL语句
cursor.execute(sql)
# 插入数据
import pymysql
# 打开数据库连接
conn = pymysql.connect('localhost', 'root', '123456', 'ajie')
# 使用cursor()方法获取操作游标
cursor = conn.cursor()
# SQL语句：向数据表中插入数据
sql = 'insert into t1(name,height,age,sex) values ( "阿杰" ,175,20,"男"); '
# 异常处理
try:
    # 执行SQL语句
    cursor.execute(sql)
    # 提交事务到数据库执行
    conn.commit()
except:
    # 如果发生错误则执行回滚操作
    conn.rollback()
# 关闭数据库连接
conn.close()

# 查询数据库
import pymysql
# 打开数据库连接
conn = pymysql.connect('localhost', 'root', '123456', )
# 使用cursor()方法获取操作游标
cursor = conn.cursor()
# SQL语句：查询
sql = "select * from ajie.t1; "
# 异常处理
try:
    # 执行SQL语句
    cursor.execute(sql)
    # 获取所有的记录列表
    results = cursor.fetchall()
    # 遍历列表
    for row in results:
        # 打印列表元素
         print(row)
except:
    print('Uable to fetch data!')
# 关闭数据库连接
conn.close()

# 更新数据
import pymysql
# 打开数据库连接
conn = pymysql.connect('localhost', 'root', '123456', 'ajie')
# 使用cursor()方法获取操作游标
cursor = conn.cursor()
# SQL语句，执行更新操作
sql = 'update t1 set age = age + 5 where sex = "男"'
# 异常处理
try:
    # 执行SQL语句
    cursor.execute(sql)
    # 提交到数据库执行
    conn.commit()
except:
    # 发生错误时回滚
    conn.rollback()
# 关闭数据库连接
conn.close()

# 删除数据
import pymysql
# 打开数据库连接
conn = pymysql.connect('localhost', 'root', '123456', 'ajie')
# 使用cursor()方法获取操作游标
cursor = conn.cursor()
# SQL语句，执行删除操作
sql = 'delete from t1 where  age >20;'
# 异常处理
try:
    # 执行SQL语句
    cursor.execute(sql)
    # 提交到数据库执行
    conn.commit()
except:
    # 发生错误时回滚
    conn.rollback()
# 关闭数据库连接
conn.close()