mysql學習（4）python操做數據庫

整理了一下前面3期學的內容後，如今練習使用python去操做數據庫

#!python3# coding:utf-8import pymysqlclass mysql_option():    def __init__(self, host, port, username, pwd, **kwargs):        '''        若是直接鏈接到具體的數據庫，只須要傳kwargs，即db = dbname        :param host:        :param port:        :param username:        :param pwd:        :param kwargs:        :return:        '''        self.conn = self.mysql_connect(host, port, username, pwd, **kwargs)        self.cursor = self.conn.cursor()    @staticmethod    def mysql_connect(host, port, username, pwd, **kwargs):        try:            connect = pymysql.connect(host = host, port = int(port), user = username, passwd = pwd, charset = 'utf8', **kwargs)            print("Mysql數據庫鏈接成功")            return connect        except Exception as ex:            print("Mysql鏈接異常,具體報錯以下：\n%s"%(ex))            return False    def create_database(self, dbname):        '''        建立數據庫        :param dbname: 數據庫名稱        :return:        '''        try:            create_db_sql = "create database if not exists %s default character set utf8 collate utf_8_general_ci;"%(dbname)            self.cursor.execute(create_db_sql)            result = self.cursor.fetcall()            print("建立%s數據庫成功%s"%(dbname, result))        except Exception as ex:            print("建立%s數據庫失敗，具體緣由以下：\n%s"%(dbname, ex))            self.cursor.close()            return False    def select_db(self, db_name):        try:            self.conn.select_db(db_name)            print("鏈接數據庫%s成功"%(db_name))        except Exception as ex:            print("鏈接數據庫%s失敗,具體緣由以下：\n%s"%(db_name, ex))            self.cursor.close()            return False    def create_table(self, table_name):        create_table_sql = "create table if not exists %s"%(table_name)        try:            self.cursor.execute(create_table_sql)            result = self.cursor.fetcall()            print("建立%s數據表成功%s"%(table_name, result))            return True        except Exception as ex:            print("建立%s數據表失敗,具體緣由以下：\n%s"%(table_name, ex))            self.cursor.close()            return False    def sql_option(self, option):        try:            self.cursor.execute(option)        except Exception as ex:            print("操做語句執行失敗,具體緣由以下：\n%s"%(ex))            self.conn.rollback()   #事務回滾            return False        else:            self.conn.commit()            print("SQL事物提交成功，提交結果：%s"%(self.cursor.rowcount))            return True        finally:            self.cursor.close()    #關閉鏈接    def show_db(self):        self.cursor.execute("show databases;")        result = self.cursor.fetchall()        return result    def show_table(self):        self.cursor.execute("show tables;")        result = self.cursor.fetchall()        return result    def show_desc(self, table_name):        sql_op = "desc %s"%(table_name)        self.cursor.execute(sql_op)        result = self.cursor.fetchall()        return result    def drop_db(self, db_name):        sql_op = "drop database %s"%(db_name)        print("警告：您將刪除數據庫%s，請再次確認刪除！(Y)確認 (N)取消"%(db_name))        confirm = input("請選擇：")        if confirm == "Y" or confirm == "y":            try:                print("開始刪除……")                self.cursor.execute(sql_op)                print("刪除數據庫%s成功"%(db_name))                return True            except Exception as ex:                print("刪除數據庫%s失敗，具體緣由：%s"%(db_name, ex))                return False            finally:                self.cursor.close()        else:            print("本次操做已取消！")            return False    def drop_table(self, table_name):        sql_op = "drop table %s"%(table_name)        print("警告：您將刪除數據表%s，請再次確認刪除！(Y)確認 (N)取消"%(table_name))        confirm = input("請選擇：")        if confirm == "Y" or confirm == "y":            print("開始刪除……")            try:                self.cursor.execute(sql_op)                print("刪除數據表%s成功%s"%(table_name))                return True            except Exception as ex:                print("刪除數據表%s失敗,具體緣由：%s"%(table_name, ex))                return False            finally:                self.cursor.close()    #關閉鏈接        else:            print("本次操做已取消！")    def close_mysql(self):        self.cursor.close()if __name__ == '__main__':    mysql_option = mysql_option("192.168.183.128", "3306", "root", "Abc123!", db = 'testdb')    # mysql_option = mysql_option("192.168.183.128", "3306", "root", "Abc123!")    # print(mysql_option.show_db()[4][0])    # db = mysql_option.show_db()[4][0]    # mysql_option.select_db(db)    # # mysql_option.show_table()    # # mysql_option.close_mysql()    # print(mysql_option.show_desc("test_tables"))    # mysql_option.drop_db("testdb02")    SQL = "select *from  user where id=1"    mysql_option.sql_option(SQL)