Python3-数据库基本操作

1 创建table

import pymysql

config = {
          'host':'localhost',
          'port':3306,
          'user':'root',
          'passwd':'root',
          'db':'test_jeff',
          'charset':'utf8'
          }

try:
    # 打开数据库连接
    conn = pymysql.connect(**config)

    # 使用 cursor() 方法创建一个游标对象 cursor
    cursor = conn.cursor()

    # 使用 execute() 方法执行 SQL，如果表存在则删除
    cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")

    # 使用预处理语句创建表
    sql = """CREATE TABLE EMPLOYEE (
             FIRST_NAME  CHAR(20) NOT NULL,
             LAST_NAME  CHAR(20),
             AGE INT,  
             SEX CHAR(1),
             INCOME FLOAT,
             PRIMARY KEY (FIRST_NAME)  
             )"""

    cursor.execute(sql)
    # 关闭游标
    cursor.close()
    conn.close()
    print("创建成功")
except Exception :print("创建失败失败")

2 插入数据

import pymysql

config = {
          'host':'localhost',
          'port':3306,
          'user':'root',
          'passwd':'root',
          'db':'test_jeff',
          'charset':'utf8'
          }
# 打开数据库连接
conn = pymysql.connect(**config)

try:
    # 使用 cursor() 方法创建一个游标对象 cursor
    cursor = conn.cursor()

    # SQL 插入语句
    sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
             LAST_NAME, AGE, SEX, INCOME)
             VALUES ('jiacheng', 'li', 26, 'M', 800)"""

    # 执行sql语句
    cursor.execute(sql)

    # commit 修改
    conn.commit()

    # 关闭游标
    cursor.close()

    # 关闭链接
    conn.close()
    print("添加成功")
except:
    print("添加记录失败")

    # 发生错误时回滚
    conn.rollback()

3 查询数据

import pymysql

config = {
          'host':'localhost',
          'port':3306,
          'user':'root',
          'passwd':'root',
          'db':'test_jeff',
          'charset':'utf8'
          }
# 打开数据库连接
conn = pymysql.connect(**config)

try:
    # 使用 cursor() 方法创建一个游标对象 cursor
    cursor = conn.cursor()

    # SQL 查询语句
    sql = "SELECT * FROM EMPLOYEE \
           WHERE INCOME > '%d'" % (1000)

    # 执行SQL语句
    cursor.execute(sql)
    # 获取所有记录列表
    results = cursor.fetchall()
    for row in results:
        fname = row[0]
        lname = row[1]
        age = row[2]
        sex = row[3]
        income = row[4]
        # 打印结果
        print("fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \
              (fname, lname, age, sex, income))

    # 关闭游标
    cursor.close()

    # 关闭链接
    conn.close()
    print("查询成功")
except:
    print("查询失败")
    # 发生错误时回滚

4 修改数据

import pymysql

config = {
          'host':'localhost',
          'port':3306,
          'user':'root',
          'passwd':'root',
          'db':'test_jeff',
          'charset':'utf8'
          }
# 打开数据库连接
conn = pymysql.connect(**config)

try:
    # 使用 cursor() 方法创建一个游标对象 cursor
    cursor = conn.cursor()

    # SQL 更新语句
    sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 " \
          "WHERE SEX = '%c'" % ('M')

    # 执行SQL语句
    cursor.execute(sql)

    # 确认修改
    conn.commit()

    # 关闭游标
    cursor.close()

    # 关闭链接
    conn.close()
    print("修改成功")
except:
    print("修改失败")

5 删除数据

import pymysql

config = {
          'host':' localhost',
          'port':3306,
          'user':'root',
          'passwd':'root',
          'db':'test_jeff',
          'charset':'utf8'
          }
# 打开数据库连接
conn = pymysql.connect(**config)

try:
    # 使用 cursor() 方法创建一个游标对象 cursor
    cursor = conn.cursor()

    # SQL 删除语句
    sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (25)

    # 执行SQL语句
    cursor.execute(sql)

    # 确认修改
    conn.commit()

    # 关闭游标
    cursor.close()

    # 关闭链接
    conn.close()
    print("删除成功")
except:
    print("删除失败")