python之pymysql操作数据库

import pymysql

def queryAll(sql,cursor):
    #使用execute()方法执行SQL语句
    cursor.execute(sql)
    #使用fetall()获取全部数据
    data=cursor.fetchall()
    return data


def insert_or_update_or_delete_data(sql,cursor,db):
    #使用execute()方法执行SQL语句
    cursor.execute(sql)
    #在数据库里增、删、改的时候，必须要进行提交，否则插入的数据不生效。
    db.commit()
    #关闭游标和数据库的连接
    cursor.close()
    db.close()


if __name__ == '__main__':
    #连接数据库
    db = pymysql.connect(host="localhost",user="root",password="root",port=3306,database="数据库名")
    
    #使用cursor()方法创建一个游标对象
    cursor = db.cursor()

    #自定义SQL语句
    sql='select * from 表名;'

    #查询所有数据
    ndata=queryAll(sql,cursor)

    for row,linedata in enumerate(ndata): #
        print(u"-------这里输出第", row , u"行数据------")
        print(linedata)
        for col,itemdata in enumerate(linedata): #按列遍历值
            print(itemdata)

    insertSQL='%s%s%s%s%s' % ('insert into 表名(列名1,列名2,...) values("',val1,'",',val2,');')
    
    updateSQL='%s%s%s%s%s' % ('update 表名 set 列名=',new_value,' where 列名=',value,';')
    
    querySQL='%s%s%s' % ('SELECT IFNULL((SELECT name from 表名 where 列名 = "',value,'"),-1);')