概述：
对于访问mysql数据库的操作，我想大家也都有一些了解。不过，因为最近在学习python，以下就用python来实现它。其中包括创建数据库和数据表、插入记录、删除记录、修改记录数据、查询数据、删除数据表、删除数据库。还有一点就是我们最好使用一个新定义的类来处理这件事。因为这会使在以后的使用过程中更加的方便（只需要导入即可，避免了重复制造轮子）。
实现功能介绍：
1.封装一个db类
2.数据库操作：创建数据库和数据表
3.数据库操作：插入记录
4.数据库操作：一次插入多条记录
5.数据库操作：删除记录
6.数据库操作：修改记录数据
7.数据库操作：一次修改多条记录数据
8.数据库操作：查询数据
9.数据库操作：删除数据表
10.数据库操作：删除数据库
数据库类的定义：
herodb.py
#!/usr/bin/env python
import mysqldb
database_name = 'hero'
class herodb:
# init class and create a database
def __init__(self, name, conn, cur):
self.name = name
self.conn = conn
self.cur = cur
try:
cur.execute('create database if not exists ' + name)
conn.select_db(name)
conn.commit()
except mysqldb.error, e:
print mysql error %d: %s % (e.args[0], e.args[1])
# create a table
def createtable(self, name):
try:
ex = self.cur.execute
if ex('show tables') == 0:
ex('create table ' + name + '(id int, name varchar(20), sex int, age int, info varchar(50))')
self.conn.commit()
except mysqldb.error, e:
print mysql error %d: %s % (e.args[0], e.args[1])
# insert single record
def insert(self, name, value):
try:
self.cur.execute('insert into ' + name + ' values(%s,%s,%s,%s,%s)', value)
except mysqldb.error, e:
print mysql error %d: %s % (e.args[0], e.args[1])
# insert more records
def insertmore(self, name, values):
try:
self.cur.executemany('insert into ' + name + ' values(%s,%s,%s,%s,%s)', values)
except mysqldb.error, e:
print mysql error %d: %s % (e.args[0], e.args[1])
# update single record from table
# name: table name
# values: waiting to update data
def updatesingle(self, name, value):
try:
# self.cur.execute('update ' + name + ' set, sex=' + str(values[2]) + ', age=' + str(values[3]) + ', info=' + str(values[4]) + ' where;')
self.cur.execute('update ' + name + ' set name=%s, sex=%s, age=%s, info=%s where id=%s;', value)
except mysqldb.error, e:
print mysql error %d: %s % (e.args[0], e.args[1])
# update some record from table
def update(self, name, values):
try:
self.cur.executemany('update ' + name + ' set name=%s, sex=%s, age=%s, info=%s where id=%s;', values)
except mysqldb.error, e:
print mysql error %d: %s % (e.args[0], e.args[1])
# get record count from db table
def getcount(self, name):
try:
count = self.cur.execute('select * from ' + name)
return count
except mysqldb.error, e:
print mysql error %d: %s % (e.args[0], e.args[1])
# select first record from database
def selectfirst(self, name):
try:
self.cur.execute('select * from ' + name + ';')
result = self.cur.fetchone()
return result
except mysqldb.error, e:
print mysql error %d: %s % (e.args[0], e.args[1])
# select last record from database
def selectlast(self, name):
try:
self.cur.execute('select * from ' + name + ' order by id desc;')
result = self.cur.fetchone()
return result
except mysqldb.error, e:
print mysql error %d: %s % (e.args[0], e.args[1])
# select next n records from database
def selectnrecord(self, name, n):
try:
self.cur.execute('select * from ' + name + ';')
results = self.cur.fetchmany(n)
return results
except mysqldb.error, e:
print mysql error %d: %s % (e.args[0], e.args[1])
# select all records
def selectall(self, name):
try:
self.cur.execute('select * from ' + name + ';')
self.cur.scroll(0, mode='absolute') # reset cursor location (mode = absolute | relative)
results = self.cur.fetchall()
return results
except mysqldb.error, e:
print mysql error %d: %s % (e.args[0], e.args[1])
# delete a record
def deletebyid(self, name, id):
try:
self.cur.execute('delete from ' + name + ' where id=%s;', id)
except mysqldb.error, e:
print mysql error %d: %s % (e.args[0], e.args[1])
# delete some record
def deletesome(self, name):
pass
# drop the table
def droptable(self, name):
try:
self.cur.execute('drop table ' + name + ';')
except mysqldb.error, e:
print mysql error %d: %s % (e.args[0], e.args[1])
# drop the database
def dropdb(self, name):
try:
self.cur.execute('drop database ' + name + ';')
except mysqldb.error, e:
print mysql error %d: %s % (e.args[0], e.args[1])
def __del__(self):
if self.cur != none:
self.cur.close()
if self.conn != none:
self.conn.close()
使用范例：
testherodb.py
#!/usr/bin/env python
import mysqldb
from herodb import herodb