python基础-03

python操作mysql数据库

创建数据表

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

import MySQLdb # MySQLdb 是用于Python链接Mysql数据库的接口

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

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

# 创建数据表SQL语句
sql = """CREATE TABLE EMPLOYEE (
         ID int NOT NULL AUTO_INCREMENT,
         FIRST_NAME  CHAR(20) NOT NULL,
         LAST_NAME  CHAR(20),
         AGE SMALLINT(4),
         SEX CHAR(1),
         INCOME FLOAT,
         PRIMARY KEY (`ID`)
         )ENGINE=InnoDB AUTO_INCREMENT=37 DEFAULT CHARSET=utf8"""

cursor.execute(sql)

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

数据表的 增 删 查 改

增

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

import MySQLdb # MySQLdb 是用于Python链接Mysql数据库的接口

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

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

# SQL 插入语句
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
         LAST_NAME, AGE, SEX, INCOME)
         VALUES ('mike', 'zhang', 18, 'M', 15000)"""
try:
   # 执行sql语句
   cursor.execute(sql)
   # 提交到数据库执行
   db.commit()
except:
   # 回滚
   db.rollback()

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

查

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

import MySQLdb # MySQLdb 是用于Python链接Mysql数据库的接口

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

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

# SQL 查询语句
sql = "SELECT * FROM EMPLOYEE"
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 获取所有记录列表
   # results = cursor.fetchone() # 查询一条记录

   # results = cursor.fetchone()  # 查询多条记录

   results = cursor.rowcount  # 这是一个只读属性，并返回执行execute()方法后影响的行数

   print(results)

except:
   print("Error: unable to fecth data")

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

改

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

import MySQLdb # MySQLdb 是用于Python链接Mysql数据库的接口

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

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

# SQL 更新语句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 \
       WHERE FIRST_NAME = '%s'" % ('mike')

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

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

删

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

import MySQLdb # MySQLdb 是用于Python链接Mysql数据库的接口

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

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

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