Python對數據庫的增刪改查操作

首先Python要連接MySQL數據庫就必須先下載連接數據庫的包，我是直接在pycharm里邊用軟件自動安裝的，然后將數據的CRUD操作封裝成了類，之后再使用的時候，直接引用這個文件對文件進行賦值即可，以下是代碼：

 

#encoding=utf-8
import pymysql
class jdbc_connect:
    '數據庫執行操作'
    #執行對象
    cursor="";
    db=False;

    #連接數據庫
    def __init__(self,host,username,password,database):
        try:
            jdbc_connect.db = pymysql.connect(host, username,password, database, charset="utf8");
            jdbc_connect.cursor = self.db.cursor();
        except BaseException:
            print("連接數據庫異常")
            self.db.close()


    '查詢數據庫 並且返還對象'
    def  select(self,sql):
        jdbc_connect.cursor.execute(sql);
        data=self.cursor.fetchall();

        return data;


    '向數據庫添加數據'
    '0成功/1失敗'
    def insert(self,sql):
       try:
        jdbc_connect.cursor.execute(sql);
        jdbc_connect.db.commit();
       except pymysql.DataError:
            jdbc_connect.db.rollback();
            print("執行添加操作失敗")
            return "1"
       else:
           return "0"
    '修改'
    def update(self,sql):
        try:
            jdbc_connect.cursor.execute(sql);
            jdbc_connect.db.commit();
        except pymysql.DataError:
            jdbc_connect.db.rollback();
            print("執行修改操作失敗")
            return "1"
        else:
            return "0"
    '刪除'
    def delete(self,sql):
        try:
            jdbc_connect.cursor.execute(sql);
            jdbc_connect.db.commit();
        except pymysql.DataError:
            jdbc_connect.db.rollback();
            print("執行刪除操作失敗")
            return "1"
        else:
            return "0"
    '關閉數據庫連接'
    def closedb(self):
        try:
            self.cursor.close();
            self.db.close();
        except BaseException:
            print("db close error")

參考鏈接：https://www.cnblogs.com/Sora-L/p/9042179.html