Python 3.x 连接数据库

由于Python统一了数据库连接的接口，所以 pymysql 和 MySQLdb 在使用方式上是类似的：

pymysql.Connect()参数说明host(str): MySQL服务器地址port(int): MySQL服务器端口号user(str): 用户名passwd(str): 密码db(str): 数据库名称charset(str): 连接编码connection对象支持的方法cursor() 使用该连接创建并返回游标commit() 提交当前事务rollback() 回滚当前事务close() 关闭连接cursor对象支持的方法execute(op) 执行一个数据库的查询命令fetchone() 取得结果集的下一行fetchmany(size) 获取结果集的下几行fetchall() 获取结果集中的所有行rowcount() 返回数据条数或影响行数close() 关闭游标对象

==================Python===================

使用Python脚本实现增删改查和事务处理，源码如下：

importpymysql.cursors#连接数据库connect =pymysql.Connect( host='localhost', port=3310, user='woider', passwd='3243', db='python', charset='utf8')#获取游标cursor =connect.cursor()#插入数据sql ="INSERT INTO trade (name, account, saving) VALUES ( '%s', '%s', %.2f )"data= ('雷军','13512345678', 10000)cursor.execute(sql%data)connect.commit()print('成功插入', cursor.rowcount,'条数据')#修改数据sql ="UPDATE trade SET saving = %.2f WHERE account = '%s'"data= (8888,'13512345678')cursor.execute(sql%data)connect.commit()print('成功修改', cursor.rowcount,'条数据')#查询数据sql ="SELECT name,saving FROM trade WHERE account = '%s'"data= ('13512345678',)cursor.execute(sql%data)forrowincursor.fetchall():print("Name:%s\tSaving:%.2f"%row)print('共查找出', cursor.rowcount,'条数据')#删除数据sql ="DELETE FROM trade WHERE account = '%s' LIMIT %d"data= ('13512345678', 1)cursor.execute(sql%data)connect.commit()print('成功删除', cursor.rowcount,'条数据')#事务处理sql_1 ="UPDATE trade SET saving = saving + 1000 WHERE account = '18012345678'"sql_2="UPDATE trade SET expend = expend + 1000 WHERE account = '18012345678'"sql_3="UPDATE trade SET income = income + 2000 WHERE account = '18012345678'"try: cursor.execute(sql_1)#储蓄增加1000cursor.execute(sql_2)#支出增加1000cursor.execute(sql_3)#收入增加2000exceptException as e: connect.rollback()#事务回滚print('事务处理失败', e)else: connect.commit()#事务提交print('事务处理成功', cursor.rowcount)#关闭连接cursor.close()connect.close()