python for MYSQL CUDA 操作套件 範例

#python demo code for MySQL drive 

#使用 pymysql 套件

import pymysql

#############################################################

class Database:

    def __init__(self, host, user, password, database, charset='utf8mb4'):

        self.conn = pymysql.connect(

            host=host,

            user=user,

            password=password,

            database=database,

            charset=charset

        )

        self.cursor = self.conn.cursor()

    def insert(self, table, data):

        # Build the INSERT statement

        columns = ', '.join(data.keys())

        values = ', '.join("'" + str(value) + "'" for value in data.values())

        sql = f"INSERT INTO {table} ({columns}) VALUES ({values})"

        # Execute the INSERT statement

        self.cursor.execute(sql)

        self.conn.commit()

    def select(self, table, conditions=None):

        # Build the SELECT statement

        sql = f"SELECT * FROM {table}"

        if conditions:

            sql += " WHERE " + " AND ".join([f"{key}='{value}'" for key, value in conditions.items()])

        # Execute the SELECT statement

        self.cursor.execute(sql)

        rows = self.cursor.fetchall()

        return rows

    def update(self, table, data, conditions):

        # Build the UPDATE statement

        set_values = ', '.join([f"{key}='{value}'" for key, value in data.items()])

        where_conditions = " AND ".join([f"{key}='{value}'" for key, value in conditions.items()])

        sql = f"UPDATE {table} SET {set_values} WHERE {where_conditions}"

        # Execute the UPDATE statement

        self.cursor.execute(sql)

        self.conn.commit()

    def delete(self, table, conditions):

        # Build the DELETE statement

        where_conditions = " AND ".join([f"{key}='{value}'" for key, value in conditions.items()])

        sql = f"DELETE FROM {table} WHERE {where_conditions}"

        # Execute the DELETE statement

        self.cursor.execute(sql)

        self.conn.commit()

    def close(self):

        self.cursor.close()

        self.conn.close()

########################################################

python class 使用範例

# Create an instance of the Database class

db = Database(host='hostname', user='username', password='password', database='database_name')

# Insert data into the database

data = {

    'column1': 'value1',

    'column2': 'value2',

    'column3': 'value3'

}

db.insert('table_name', data)

# Select data from the database

rows = db.select('table_name')

for row in rows:

    print(row)

# Update data in the database

data = {

    'column2':