python3用pymysql连接mysql数据库进行操作

原创文章，转载请注明出处

pymysql是python3特有的，python2没有，只能用mysqldb

需提前建好数据库和对应的表

第一步，安装pymysql

pip install PyMySQL

第二步，数据库连接及获得游标对象 cursor

# 打开数据库连接
db = pymysql.connect("localhost","root","123456","TESTDB" )
# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()

connect的参数分别是（连接地址，数据库用户名，数据库密码，数据库名称，端口(默认3306可省略)）

第三步，增删改除了sql语句其它都一样，即插入，更新，删除的操作步骤是一样的，只是对应的sql语句不同而已

# 插入操作的sql语句1
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
         LAST_NAME, AGE, SEX, INCOME)
         VALUES ('Bai', 'LI', 24, 'M', 9000)"""
也可以这样写
#插入操作的sql语句2
sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \
       LAST_NAME, AGE, SEX, INCOME) \
       VALUES (%s, %s,  %s,  %s,  %s )" % \
       ('Bai', 'LI', 24, 'M', 9000)

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

#删除操作的sql语句
sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (24)

然后下面步骤是一样的

try:
   # 执行sql语句
   cursor.execute(sql)
   # 提交到数据库执行
   db.commit()
except:
   # 如果发生错误则回滚
   db.rollback()

第三步如果是查询，跟增删改不太一样

# SQL 查询语句
sql = "SELECT * FROM EMPLOYEE \
       WHERE INCOME > %s" % (9000)
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 获取所有记录列表
   results = cursor.fetchall()
   for row in results:
      id= row[0]
      fname = row[1]
      income= row[4]
       # 打印结果
      print ("id=%s,fname=%s,income=%s" % \
             (id, fname, income ))
except:
   print ("Error: unable to fetch data")

补充：

1、fetchone()：获取查询结果的第1条数据
　　2、fetchmany(n)：获取n条数据
　　3、fetchall()：获取所有的数据
4、rowcount: 这是一个只读属性，并返回执行execute()方法后影响的行数
##fetchmany(n)和fetchall()得到的结果一定是一个大元组套着小元组((),(),()...)

最后第四步也是都一样也是最重要记得的，就是关闭数据库连接

db.close()

python3用pymysql连接mysql数据库进行操作

猜你喜欢