python 操作 MySQL (pymysql)

2018-09-04  本文已影响0人  奥特曼255

综述

pymysql.png

查询

from pymysql import *


def main():
    # 创建 connection 对象,连接数据库
    conn = connect(host='localhost', port=3306, database='your_db', user='root', password='your_psw', charset='utf8')
    # 获取 cursor 对象
    cs1 = conn.cursor()
    
    # 调用 execute 方法,来执行 sql 语句
    # execute 方法,默认返回值为 生效行数
    count = cs1.execute('select id,name from goods where id>=4')
    # 调用 cursor 的 fetchone() 逐个查询结果、fetchmany(3) 查询3行,fetchall() 查询所有
    for i in range(count):
        result = cs1.fetchone()
        print(result)
    
    # 关闭 cursor 对象,关闭 connection 连接
    cs1.close()
    conn.close()


if __name__ == '__name__':
    main()

增删改

因为增删改会修改数据库,所以,除了要写不一样的 SQL 语句,还要多加一个提交的步骤。

from pymysql import *


def main():
    # 创建 connection 对象,连接数据库
    conn = connect(host='localhost', port=3306, database='your_db', user='root', password='your_psw', charset='utf8')
    # 获取 cursor 对象
    cs1 = conn.cursor()

    # 增加
    count = cs1.execute('insert into goods_cates (name) values("硬盘")')
    # 更新
    count = cs1.execute('update goods_cates set name="机械硬盘" where name="硬盘"')
    # 删除
    count = cs1.execute('delete from good_cates where id=6')

    # 提交之前的操作
    # 如果之前已经执行过多次的 execute,那么就都进行提交
    conn.commit()
    # 撤销之前的操作,回滚
    # conn.rollback()

    # 关闭 cursor 对象,关闭 connection 连接
    cs1.close()
    conn.close()


if __name__ == '__main__':
    main()
上一篇下一篇

猜你喜欢

热点阅读