Python对MySql增删改查

pip install pymysql

import pymysql

db_config = {

    'host': '127.0.0.1(ip)',

    'port': 3306,

    'user': '账号',

    'password': '密码',

    'db': '数据库名',

    'charset': 'utf8'

}

# 建立连接

conn = pymysql.connect(**db_config)

#   连接是不能操作数据库的,需要生成游标来操作

#   获取cursor

cur = conn.cursor()

基本使用：insert 、 delete 、 update 、 select

try

try:

    #   增（insert into values）

    #   指定字段

    # sql_insert = "insert into temp(name,age) values ('jy',11),('nh',22),('fe',33)"

    #   全字段

    # sql_insert = "insert into temp values (1, 'bk', 44, 'f')"

    #   执行sql语句

    # cur.execute(sql_insert)

    #   删（delete from where）

    #   删除表中满足条件的数据

    # sql_delete = "delete from temp where id > 5"

    #   删除表中所有数据

    # sql_delete = "delete from temp"

    #   执行sql语句

    # cur.execute(sql_delete)

    #   改（update set where）

    #   修改满足条件的多个字段

    # sql_update = "update temp set id = 0, sex = 'm' where name = 'jy' "

    #   修改满足条件的单个字段

    # sql_update = "update temp set sex = 'f' where id is null"

    #   修改所有数据

    # sql_update = "update temp set sex = 'noth'"

    #   执行sql语句

    # cur.execute(sql_update)

    #   查（select from where）

    sql_select = "select * from temp"

    #   执行SQL命令，然后返回生效行数

    #   SQL语句都是通过execute方法执行

    num = cur.execute(sql_select)

    # print(num)

    #   获取结果

    #   取出所有        fetchall()

    for i in cur.fetchall():

        print(i)

    #   取出一条        fetchaone()

    # print(cur.fetchone())

    #   取出具体几条    fetchamany(num)

    # print(cur.fetchmany(5))

    #   提交事务

    conn.commit()

except

except Exception as message:

    #   打印异常

    print(message)

    #   发生异常，回滚事务

    conn.rollback()

finally

finally:

    #   关闭游标

    cur.close()

    #   关闭连接

    conn.close()

巴特西

Python对MySql增删改查

pip install pymysql

基本使用：insert 、 delete 、 update 、 select

try

except

finally

最新文章

热门文章