pip install pymysql3

#导入pymysql的包 
import pymysql 
try: 
    #获取一个数据库连接，注意如果是UTF-8类型的，需要制定数据库 
    conn=pymysql.connect(host='localhost',user='pythondb',passwd='pythondb',db='pythondb',port=3306,charset='utf8') 
    cursor=conn.cursor()#获取一个游标 
 
    #创建user表   
    cursor.execute("drop table if exists user")   
    sql="""CREATE TABLE IF NOT EXISTS `user` (  
          `id` int(11) NOT NULL AUTO_INCREMENT,  
          `name` varchar(255) NOT NULL,  
          `age` int(11) NOT NULL,  
          PRIMARY KEY (`id`)  
        ) ENGINE=InnoDB  DEFAULT CHARSET=utf8 AUTO_INCREMENT=0"""   
       
    cursor.execute(sql)   
 
    #user插入数据   
    sql="""INSERT INTO `user` (`name`, `age`) VALUES  
    ('test1', 1),  
    ('test2', 2),  
    ('test3', 3),  
    ('test4', 4),  
    ('test5', 5),  
    ('test6', 6);"""   
       
    try:   
       # 执行sql语句   
       cursor.execute(sql)   
       # 提交到数据库执行   
       conn.commit()   
    except:   
       # 如果发生错误则回滚   
       conn.rollback() 
 
    #更新   
    id=1   
    sql="update user set age=100 where id='%s'" % (id)   
    try:   
        cursor.execute(sql)   
        conn.commit()   
    except:   
        conn.rollback()   
 
    #删除   
    id=2   
    sql="delete from user where id='%s'" % (id)   
    try:   
        cursor.execute(sql)   
        conn.commit()   
    except:   
        conn.rollback()   
 
    #查询  
    cursor.execute('select * from user') 
    results=cursor.fetchall()   
    # 判断是否有记录数 
    if len(results) == 0: 
        check_code = 0 
    else: 
        check_code = 1 
    #取出数据　 
    for row in results:   
        name=row[0]   
        age=row[1]   
        #print(type(row[1])) #打印变量类型 
        print ("name=%s,age=%s" %(age, name))   
 
    cursor.close()#关闭游标 
    conn.close()#释放数据库资源 
except  Exception :print("失败")