class cmysql(object):
def mysqlselect(self,ahost,auser,apasswd,adb,acode,sql):
import sys,string,os
import MySQLdb
conn=MySQLdb.connect(host=ahost,user=auser,passwd=apasswd,db=adb,charset=acode)
cursor=conn.cursor()
#sql = "select * from product"
cursor.execute(sql)
alldata = cursor.fetchall()
if alldata:
for rec in alldata:
print rec[0],rec[1]
cursor.close()
conn.close()
def mysqlalterdate(self,ahost,auser,apasswd,adb,acode,sql):
import sys,string,os
import MySQLdb
conn=MySQLdb.connect(host=ahost,user=auser,passwd=apasswd,db=adb,charset=acode)
cursor=conn.cursor()
flag = cursor.execute(sql)
conn.commit()
if flag:
print 'Alter Data Sucess!'
cursor.close()
conn.close()
#定义一个函数，查询SQL语句的函数
ms = cmysql()
host='localhost'
user='root'
passwd='tester'
db='test'
charset='utf8'
sql_select = "select * from T1"
sql_insert = 'INSERT INTO T1 VALUES (0003,\'fang\')'
sql_update = 'UPDATE T1 SET ID =1999 where name=\'xiao\''
sql_delete='delete from t1 where id=1999'
#更新语句
ms.mysqlalterdate(host,user,passwd,db,charset,sql_insert)
#更新数据
ms.mysqlalterdate(host,user,passwd,db,charset,sql_update)
#清理数据
ms.mysqlalterdate(host,user,passwd,db,charset,sql_delete)
#查询语句
ms.mysqlselect(host,user,passwd,db,charset,sql_select)
