记录一下python mysql的操作方式

安装python mysql库

pip install pymysql

使用方式

第一步就是通过import方式导入mysql库

import pymysql

连接到mysql数据库

pymysql.connect(host="127.0.0.1", user="root", passwd="root pwd", db="db name")

参数说明：
host:数据库主机名.默认是用本地主机.
user:数据库登陆名.默认是当前用户.
passwd:数据库登陆的秘密.默认为空.
db:要使用的数据库名.没有默认值,如果在这里设置了 db,则连接时直接连接到 Mysql 的 db 设置的数据库中.

切换数据库

在连接到数据库之后，如果想要切换到其它的数据库，可以通过一下方式：

conn.select_db('mysql')

这个就切换到了mysql数据库。

操作数据库

pymysql使用游标（指针）的方式操作数据库。

cur = conn.cursor()

pymysql操作数据库，主要是通过python将mysql的命令提交到数据库侧执行，并获取返回的结果。因此我们有必要学会mysql的基本操作命令，然后通过cursor的方法execute来执行。

创建数据表

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import pymsql

# 打开数据库连接
db = pymsql.connect("localhost", "testuser", "test123", "TESTDB")

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# 如果数据表已经存在使用 execute() 方法删除表。
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")

# 创建数据表SQL语句
sql = """CREATE TABLE EMPLOYEE (
         FIRST_NAME  CHAR(20) NOT NULL,
         LAST_NAME  CHAR(20),
         AGE INT,  
         SEX CHAR(1),
         INCOME FLOAT )"""

cursor.execute(sql)

# 关闭数据库连接
db.close()

数据库插入

# SQL 插入语句
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
         LAST_NAME, AGE, SEX, INCOME)
         VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""
try:
   # 执行sql语句
   cursor.execute(sql)
   # 提交到数据库执行
   db.commit()
except:
   # Rollback in case there is any error
   db.rollback()

如果要插入的数据不是固定的，还可以通过一下方式，通过变量传递数据

# SQL 插入语句
sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \
       LAST_NAME, AGE, SEX, INCOME) \
       VALUES (%s, %s, %s, %s, %s )" % \
       ('Mac', 'Mohan', 20, 'M', 2000)
try:
   # 执行sql语句
   cursor.execute(sql)
   # 提交到数据库执行
   db.commit()
except:
   # 发生错误时回滚
   db.rollback()

我们知道execute的原型是execute(cmd, args)，也就是说，我们通过可以在execute函数中通过参数形式传递。

con.execute('insert into Login values(%s, %s)' % \
             (user_id, password))
或者
con.execute('insert into Login values(%s, %s)' ,
             (user_id, password))

参数以元组的形式传递。

数据库查询

Python查询Mysql使用 fetchone() 方法获取单条数据, 使用fetchall() 方法获取多条数据。

  • fetchone(): 该方法获取下一个查询结果集。结果集是一个对象
  • fetchall():接收全部的返回结果行.
  • rowcount: 这是一个只读属性，并返回执行execute()方法后影响的行数。
# SQL 查询语句
sql = "SELECT * FROM EMPLOYEE \
       WHERE INCOME > %s" % (1000)
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 获取所有记录列表
   results = cursor.fetchall()
   for row in results:
      fname = row[0]
      lname = row[1]
      age = row[2]
      sex = row[3]
      income = row[4]
      # 打印结果
      print "fname=%s,lname=%s,age=%s,sex=%s,income=%s" % \
             (fname, lname, age, sex, income )
except:
   print "Error: unable to fecth data"

rawcount = cursor.execute(sql)
这里可以通过rwacount的结果，判断数据表中是否存在某个数据，如果存在有多少行。

数据库更新

# SQL 更新语句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M')
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 提交到数据库执行
   db.commit()
except:
   # 发生错误时回滚
   db.rollback()

数据库删除

# SQL 删除语句
sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (20)
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 提交修改
   db.commit()
except:
   # 发生错误时回滚
   db.rollback()

在数据库操作的插入、更新和删除操作时，应当在执行完命令之后通过commit提交修改。
这个涉及到数据库事务机制的数据一致性。
事务的4个属性：原子性、一致性、隔离性、持久性。

  • 原子性（atomicity）。一个事务是一个不可分割的工作单位，事务中包括的诸操作要么都做，要么都不做。
  • 一致性（consistency）。事务必须是使数据库从一个一致性状态变到另一个一致性状态。一致性与原子性是密切相关的。
  • 隔离性（isolation）。一个事务的执行不能被其他事务干扰。即一个事务内部的操作及使用的数据对并发的其他事务是隔离的，并发执行的各个事务之间不能互相干扰。
  • 持久性（durability）。持续性也称永久性（permanence），指一个事务一旦提交，它对数据库中数据的改变就应该是永久性的。接下来的其他操作或故障不应该对其有任何影响。

pymysql的事务提供l了两个方法commit和rollback，如下：

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

对于支持事务的数据库， 在Python数据库编程中，当游标建立之时，就自动开始了一个隐形的数据库事务。

commit()方法游标的所有更新操作，rollback（）方法回滚当前游标的所有操作。每一个方法都开始了一个新的事务。

本文参考：

最后修改：2019 年 05 月 06 日 11 : 33 AM
© 允许规范转载