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

import pymysql

########連接數(shù)據(jù)庫(kù)###############
def createConnection():
    db = pymysql.Connect(
        host='127.0.0.1',
        port=3306,
        user='root',
        passwd='root',
        db='mydbdemo',
        charset='utf8'
    )
    return db

########執(zhí)行SELECT語(yǔ)句咐低，返回單條數(shù)據(jù)###############
def executeSelectONEback(sqlstring):
    try:
        db = createConnection() # 連接數(shù)據(jù)庫(kù)
        cursor = db.cursor()
        cursor.execute(sqlstring)
        dataone = cursor.fetchone()
        return dataone
    except:
        return False
    finally:
        db.close()# 關(guān)閉數(shù)據(jù)庫(kù)連接




########執(zhí)行SELECT語(yǔ)句，返回多條數(shù)據(jù)###############
def executeSelectAllback(sqlstring):
    try:
        db = createConnection()  # 連接數(shù)據(jù)庫(kù)
        cursor = db.cursor()
        cursor.execute(sqlstring)
        dataall = cursor.fetchall()
        return dataall
    except:
        return False
    finally:
        db.close()# 關(guān)閉數(shù)據(jù)庫(kù)連接


########執(zhí)行INSERT語(yǔ)句敛惊，返回id主鍵###############
def executeInsertIDback(sqlstring):
    try:
        db = createConnection()  # 連接數(shù)據(jù)庫(kù)
        cursor = db.cursor()
        cursor.execute(sqlstring)
        db.commit()
        the_id = int(cursor.lastrowid)
        return the_id
    except:
        db.rollback()
        return False
    finally:
        db.close()         # 關(guān)閉數(shù)據(jù)庫(kù)連接


########執(zhí)行UPDATE 語(yǔ)句渊鞋，無(wú)返回###############
def executeUpdateNOback(sqlstring):
    try:
        db = createConnection() # 連接數(shù)據(jù)庫(kù)
        cursor = db.cursor()
        cursor.execute(sqlstring)
        db.commit()
        return True
    except:
        db.rollback()
        return False
    finally:
        db.close()# 關(guān)閉數(shù)據(jù)庫(kù)連接


########執(zhí)行DELETE語(yǔ)句，無(wú)返回###############
def executeDeleteNOback(sqlstring):
    try:
        db = createConnection() # 連接數(shù)據(jù)庫(kù)
        cursor = db.cursor()
        cursor.execute(sqlstring)
        db.commit()
        return True
    except:
        db.rollback()
        return False
    finally:
        db.close()# 關(guān)閉數(shù)據(jù)庫(kù)連接


########執(zhí)行CREATE語(yǔ)句瞧挤，無(wú)返回###############
def executeCreateNOback(sqlstring):
    try:
        db = createConnection()  # 連接數(shù)據(jù)庫(kù)
        cursor = db.cursor()
        cursor.execute(sqlstring)
        return True
    except:
        db.rollback()
        return False
    finally:
        db.close()# 關(guān)閉數(shù)據(jù)庫(kù)連接