python操作mysql数据库的精美实用模块

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import pymysql

########连接数据库###############
def createConnection():
    db = pymysql.Connect(
        host='127.0.0.1',
        port=3306,
        user='root',
        passwd='root',
        db='mydbdemo',
        charset='utf8'
    )
    return db

########执行SELECT语句，返回单条数据###############
def executeSelectONEback(sqlstring):
    try:
        db = createConnection() # 连接数据库
        cursor = db.cursor()
        cursor.execute(sqlstring)
        dataone = cursor.fetchone()
        return dataone
    except:
        return False
    finally:
        db.close()# 关闭数据库连接




########执行SELECT语句，返回多条数据###############
def executeSelectAllback(sqlstring):
    try:
        db = createConnection()  # 连接数据库
        cursor = db.cursor()
        cursor.execute(sqlstring)
        dataall = cursor.fetchall()
        return dataall
    except:
        return False
    finally:
        db.close()# 关闭数据库连接


########执行INSERT语句，返回id主键###############
def executeInsertIDback(sqlstring):
    try:
        db = createConnection()  # 连接数据库
        cursor = db.cursor()
        cursor.execute(sqlstring)
        db.commit()
        the_id = int(cursor.lastrowid)
        return the_id
    except:
        db.rollback()
        return False
    finally:
        db.close()         # 关闭数据库连接


########执行UPDATE 语句，无返回###############
def executeUpdateNOback(sqlstring):
    try:
        db = createConnection() # 连接数据库
        cursor = db.cursor()
        cursor.execute(sqlstring)
        db.commit()
        return True
    except:
        db.rollback()
        return False
    finally:
        db.close()# 关闭数据库连接


########执行DELETE语句，无返回###############
def executeDeleteNOback(sqlstring):
    try:
        db = createConnection() # 连接数据库
        cursor = db.cursor()
        cursor.execute(sqlstring)
        db.commit()
        return True
    except:
        db.rollback()
        return False
    finally:
        db.close()# 关闭数据库连接


########执行CREATE语句，无返回###############
def executeCreateNOback(sqlstring):
    try:
        db = createConnection()  # 连接数据库
        cursor = db.cursor()
        cursor.execute(sqlstring)
        return True
    except:
        db.rollback()
        return False
    finally:
        db.close()# 关闭数据库连接

        

          
        
        
        

          

          AI 代码解读