la conexión de base de datos MySQL python3

En este trabajo, se introduce python3 uso PyMySQL conectarse a la base de datos, y CRUD sencillo.

¿Cuál es PyMySQL?

PyMySQL para una versión del servidor MySQL conexión de base de datos en Python3.x, python2 en uso MySQLdb.

PyMySQL sigue Python especificación v2.0 API de base de datos y contiene la biblioteca cliente de MySQL-Python puro.

instalación PyMySQL

Antes de utilizar PyMySQL, tenemos que garantizar instalado PyMySQL.

PyMySQL de descarga: https: //github.com/PyMySQL/PyMySQL.

Si no está instalado, podemos usar el siguiente comando para instalar la última versión de PyMySQL:

$ pip install PyMySQL

Si su sistema no admite comandos de pepita, puede utilizar los siguientes productos:

1, utilizando el comando git para descargar el paquete de instalación (también se puede descargar de forma manual):

$ git clone https://github.com/PyMySQL/PyMySQL
$ cd PyMySQL/
$ python3 setup.py install

2, si usted necesita para desarrollar un número de versión, puede utilizar el comando curl para instalar:

$ # X.X 为 PyMySQL 的版本号
$ curl -L https://github.com/PyMySQL/PyMySQL/tarball/pymysql-X.X | tar xz
$ cd PyMySQL*
$ python3 setup.py install
$ # 现在你可以删除 PyMySQL* 目录

Nota: Asegúrese de que tiene privilegios de superusuario para instalar los módulos descritos anteriormente.

El proceso de instalación puede aparecer "ImportError: Sin módulo denominado setuptools" mensaje de error, lo que significa que no tiene que instalar setuptools, puede acceder a https://pypi.python.org/pypi/setuptools encontrar el método de instalación de cada sistema.

Ejemplo de instalación de Linux:

$ wget https://bootstrap.pypa.io/ez_setup.py
$ python3 ez_setup.py

La conectividad de base de datos

Antes de conectarse a la base de datos, asegúrese de que los siguientes elementos:

• Se ha creado una base de datos TESTDB.
• En la base de datos TESTDB de haber creado la tabla EMPLOYEE
• EMPLEADOS FIRST_NAME campo de tabla, APELLIDOS, edad, sexo e ingresos.
• Los usuarios se conectan a la base de datos utilizando TESTDB llamado "testuser", contraseña "test123", puede establecer su propio nombre de usuario y contraseña directamente o raíz, licencia de usuario de base de datos MySQL, por favor utilice el comando Grant.
• En la máquina ya instalada módulo de Python MySQLdb.
• Si no está familiarizado con la instrucción SQL, puede visitar nuestra base tutorial de SQL

Ejemplo:

Los siguientes ejemplos de TESTDB Mysql enlace de datos:

#!/usr/bin/python3

import pymysql

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

# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()

# 使用 execute()  方法执行 SQL 查询 
cursor.execute("SELECT VERSION()")

# 使用 fetchone() 方法获取单条数据.
data = cursor.fetchone()

print ("Database version : %s " % data)

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

La aplicación de la secuencia de comandos anterior da salida a los resultados son los siguientes:

Database version : 5.5.20-log

Crear una tabla de base de datos

Si existe la conexión de base de datos, podemos usar el método execute () para crear tablas de la base de datos, cree una tabla EMPLOYEE se muestra en la siguiente:

#!/usr/bin/python3

import pymysql

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

# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()

# 使用 execute() 方法执行 SQL，如果表存在则删除
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")

# 使用预处理语句创建表
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()

insertar base de datos

En el siguiente ejemplo se utiliza ejecutar una instrucción SQL INSERT para insertar un registro a la tabla EMPLOYEE:

#!/usr/bin/python3

import pymysql

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

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

# 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:
   # 如果发生错误则回滚
   db.rollback()

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

El ejemplo anterior también se puede escribir como sigue:

#!/usr/bin/python3

import pymysql

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

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

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

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

El siguiente código utiliza variables para pasar parámetros a una instrucción SQL:

..................................
user_id = "test123"
password = "password"

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

consultas de bases de datos

Python consulta MySQL utilizando el método fetchone () para obtener un solo dato utilizando fetchall () para obtener una pluralidad de datos.

• fetchone (): Este método obtiene el siguiente conjunto de resultados de consulta.El conjunto de resultados es un objetivo
• fetchall (): devuelve el resultado de recibir todas las filas.
• recuento de filas: Este es un atributo de sólo lectura, y devuelve la ejecución ejecutar el método () después de que el número de filas afectadas.

Ejemplo:

salario campo de datos Descubre tabla EMPLOYEE (salario) es más grande que todos 1000:

#!/usr/bin/python3

import pymysql

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

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

# SQL 查询语句
sql = "SELECT * FROM EMPLOYEE \
       WHERE INCOME > '%d'" % (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=%d,sex=%s,income=%d" % \
             (fname, lname, age, sex, income ))
except:
   print ("Error: unable to fecth data")

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

Los resultados de la ejecución de secuencias de comandos anterior son los siguientes:

fname=Mac, lname=Mohan, age=20, sex=M, income=2000

actualizaciones de la base

Datos operación de actualización para actualizar la tabla de datos, los siguientes ejemplos TestDB campo SEXO mesa de todos los cambios en 'M', campo de AGE se incrementa en 1:

#!/usr/bin/python3

import pymysql

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

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

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

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

supresión

Borrar datos de borrar los datos de la tabla, el siguiente ejemplo demuestra borrar datos en la tabla EMPLOYEE AGE es mayor que 20, todos los datos:

#!/usr/bin/python3

import pymysql

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

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

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

# 关闭连接
db.close()

Asuntos ejecutivos

mecanismo de transacción para asegurar la consistencia de los datos.

Los servicios deben tener cuatro propiedades: atomicidad, coherencia, aislamiento, durabilidad. Estas cuatro propiedades se refieren como las propiedades ACID menudo.

• Atómica (atomicidad). Una transacción es una unidad de trabajo indivisible, tales operaciones se incluyen en la transacción ya sea hacer o no hacer.
• Coherencia (consistencia). Los servicios deben ser cambiadas para hacer la base de datos de un estado consistente a otro estado consistente. La consistencia y la atomicidad están estrechamente relacionados.
• Aislamiento (aislamiento). Ejecutar una transacción no puede ser otra interferencia de las transacciones. Esa es una transacción de funcionamiento interno y el uso de otro concurrentemente transacción de datos está aislado y no puede interferir entre sí entre las transacciones individuales se ejecutan concurrentemente.
• Persistencia (durabilidad). Persistente también llamado permanente (permanencia), que significa que una vez que se confirma una transacción, modificar los datos en la base de datos debe ser permanente. Los siguientes operaciones o su fracaso no debería tener ningún impacto.

Python DB API 2.0 proporciona dos métodos de operación de confirmación o retrotracción.

Ejemplos

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

Para bases de datos transaccionales, programación de bases de datos en Python, cuando se establece el cursor, se inicia automáticamente una base de datos de transacciones invisibles.

método commit () para todo el método de actualización de cursores, rollback () para hacer retroceder todas las operaciones del cursor actual. Cada método se ha iniciado un nuevo negocio.

Control de errores

API DB define algunos errores y el funcionamiento anormal de la base de datos, la siguiente tabla se enumeran los errores y excepciones: