安装pymysql

pip install pymysql

import pymysql

# 打开数据库连接

db = pymysql.connect(“localhost”,“root”,“root”,“cis_prod” )

print(‘db %s’%db)

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

cursor = db.cursor()
goods_info_sql=“SELECT goods_info_id, goods_name,goods_code,goods_barcode from goods_info where goods_name like ‘%%%s%%’”%(“听”)

# 使用 execute()  方法执行 SQL 查询

cursor.execute(goods_info_sql)

# 使用 fetchone() 方法获取单条数据. fetchall全部数据 

results = cursor.fetchall()

for row in results:
print(type(row),’ ',row[0],row[1],row[2],row[3])

db.close()

### 连接

import pymysql

打开数据库连接

db = pymysql.connect("localhost","root","123456","TESTDB" )

使用 cursor() 方法创建一个游标对象 cursor

cursor = db.cursor()

使用 execute() 方法执行 SQL 查询

cursor.execute("SELECT VERSION()")

使用 fetchone() 方法获取单条数据.

data = cursor.fetchone()
 
print ("Database version : %s " % data)
 
# 关闭数据库连接
db.close()

创建数据库表

import pymysql
 
# 打开数据库连接
db = pymysql.connect("localhost","root","123456","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()

插入数据

# !/usr/bin/python
# -*-coding:utf-8-*-
# @Author: 刘楠
# @Time: 2019/12/2 16:40
# @File    : mysql_inster.py
import pymysql

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

print('db  %s' % db)

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

# SQL 插入语句
sql = """INSERT INTO employee(FIRST_NAME,
         LAST_NAME, AGE, SEX, INCOME)
         VALUES ('aaa', 'aaa', 100, 'F', 6000)"""

try:
    cursor.execute(sql)
    db.commit()
except:
    # 如果发生错误则回滚
    db.rollback()


db.close()

查询

# !/usr/bin/python
# -*-coding:utf-8-*-
# @Author: 刘楠
# @Time: 2019/12/2 16:44
# @File    : mysql_select.py
# fetchone(): 该方法获取下一个查询结果集。结果集是一个对象
# fetchall(): 接收全部的返回结果行.
# rowcount: 这是一个只读属性，并返回执行execute()方法后影响的行数
import  pymysql

db = pymysql.connect('localhost','root','root','testdb')


cursor = db.cursor()

# SQL 查询语句
sql = "SELECT * FROM EMPLOYEE \
       WHERE INCOME > '%d'" % (600)


try:
    cursor.execute(sql)
    results = cursor.fetchall()

    for row in results:
        print('row    ',row[0],row[1],row[2],row[3],row[4])
except:
    print('db error')

db.close()

更新

# !/usr/bin/python
# -*-coding:utf-8-*-
# @Author: 刘楠
# @Time: 2019/12/2 16:49
# @File    : update_mysql.py

import pymysql

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

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

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

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

删除

# !/usr/bin/python
# -*-coding:utf-8-*-
# @Author: 刘楠
# @Time: 2019/12/2 16:50
# @File    : del_mysql.py

import pymysql

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

# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 删除语句
sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20)
try:
    # 执行SQL语句
    cursor.execute(sql)
    # 提交修改
    db.commit()
    print('success')
except:
    # 发生错误时回滚
    db.rollback()

# 关闭连接
db.close()

Python DB API 2.0 的事务提供了两个方法 commit或 rollback。

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

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