1、安装MySQL-python-1.2.3
2、然后连接数据库
3、执行数据库的增、删、改、查
# -*- coding: utf-8 -*- import logging import MySQLdb import config def get_db_con(): con = MySQLdb.connect(host="192.168.6.82", port=3306, user="root", passwd="123456",db="test") return con def query_db(sql): con = get_db_con() cursor = con.cursor() cursor.execute(sql) data = cursor.fetchall() cursor.close() con.close() return data def change_db(sql): con = get_db_con() cursor = con.cursor() try: cursor.execute(sql) logging.info(sql) con.commit() except Exception, e: con.rollback() logging.error(e.message) if __name__ == "__main__": sqlA = "show tables" sqlB = "select * from tablename" #print change_db(sql) print sqlA print query_db(sqlA) print sqlB print query_db(sqlB)
