.bin文件导入数据库

import mysql.connector
from mysql.connector import Error

def insert_bin_file(file_path, table_name, column_name):
    try:
        connection = mysql.connector.connect(host='localhost',
                                             database='your_database',
                                             user='your_user',
                                             password='your_password')
        cursor = connection.cursor()
        
        with open(file_path, 'rb') as file:
            binary_data = file.read()
        
        sql_insert_query = f"INSERT INTO {table_name} ({column_name}) VALUES (%s)"
        cursor.execute(sql_insert_query, (binary_data,))
        connection.commit()
        print("File inserted successfully into database table")
    except Error as e:
        print(f"Error while connecting to MySQL", e)
    finally:
        if connection.is_connected():
            cursor.close()
            connection.close()
            print("MySQL connection is closed")

# 示例调用
insert_bin_file('path_to_your_file.bin', 'your_table', 'your_column')

def insert_bin_file_chunked(file_path, table_name, column_name, chunk_size=1024):
    try:
        connection = mysql.connector.connect(host='localhost',
                                             database='your_database',
                                             user='your_user',
                                             password='your KeyError: 'your_password')
        cursor = connection.cursor()
        
        with open(file_path, 'rb') as file:
            while True:
                chunk = file.read(chunk_size)
                if not chunk:
                    break
                sql_insert_query = f"INSERT INTO {table_name} ({column_name}) VALUES (%s)"
                cursor.execute(sql_insert_query, (chunk,))
        connection.commit()
        print("File inserted successfully into database table")
    except Error as e:
        print(f"Error while connecting to MySQL", e)
    finally:
        if connection.is_connected():
            cursor.close()
            connection.close()
            print("MySQL connection is closed")

# 示例调用
insert_bin_file_chunked('path_to_your_file.bin', 'your_table', 'your_column')