5分钟立马学会使用python的pymysql库操作Mysql

向右看齐 2023-10-07 21:16 75阅读 0赞

### 一、py操作数据库流程 ###

1.  数据库初始化连接
2.  创建游标，编写sql
3.  执行SQL

### 二、数据库初始化连接 ###

def init_db():
        host = 'localhost'
        user = '你的账号'
        password = '你的密码'
        database = '***'
        try:
            db = pymysql.connect(host=host, user=user, password=password, database=database, charset='utf8')
            return db
        except:
            print('数据库连接失败！')

### 三、py创建表、增删改查 ###

### 1、创建表 ###

1.  创建游标
2.  编写sql
3.  执行sql

cursor = db.cursor()
    SQL="省略..."
    cursor.execute(SQL)

### 2、插入数据、删除数据、修改数据 ###

1.  创建游标
2.  编写SQL
3.  执行语句，提交事务，若插入失败则回滚。

注：以插入数据为例，删除与修改数据仅差别在sql语句，流程一致。

#要插入的数据
    link='hhh'
    cover='test'
    cursor = db.cursor()
    sql = 'insert into douban_top250(details_link,film_cover)values("%s","%s")' % (link, cover)
    try:
       # 执行SQL语句
       cursor.execute(sql)
       db.commit()
    except:
       # 发生错误时回滚
       db.rollback()

### 3、查找数据 ###

1.  创建游标、编写查询SQL
2.  游标执行SQL语句
3.  通过游标获取查询到的数据

cursor = db.cursor()
    #查询SQL语句
    sql = "SELECT * FROM EMPLOYEE"
    # 执行SQL语句
    cursor.execute(sql)
    #获取所有记录
    results = cursor.fetchall()

注：

*  fetchone(): 该方法获取下一个查询结果集。结果集是一个对象。
 *  fetchall(): 接收全部的返回结果行。
 *  rowcount: 这是一个只读属性，并返回执行execute()方法后影响的行数。

### 四、执行事务 ###

事务提供了两个方法 commit 或 rollback。commit用于执行游标的操作，rollback用于回滚游标的操作。

# SQL删除记录语句
    sql = "DELETE FROM BOOK WHERE ID=1"
    try:
       # 执行SQL语句
       cursor.execute(sql)
       # 向数据库提交
       db.commit()
    except:
       # 发生错误时回滚
       db.rollback()