txt导入mysql数据库

import os

file_path = 'path/to/your/file.txt'
if not os.path.exists(file_path):
    print("文件路径错误")
elif not os.access(file_path, os.R_OK):
    print("文件权限不足")
else:
    # 继续读取文件
    pass

import csv

with open(file_path, 'r') as file:
    reader = csv.reader(file, delimiter='\t')  # 根据实际情况调整分隔符
    for row in reader:
        if len(row) != expected_columns:
            print(f"数据格式错误: {row}")
        else:
            # 继续处理数据
            pass

import mysql.connector

try:
    conn = mysql.connector.connect(
        host='your_host',
        user='your_user',
        password='your_password',
        database='your_database'
    )
except mysql.connector.Error as err:
    print(f"数据库连接失败: {err}")
else:
    # 继续插入数据
    pass

cursor = conn.cursor()
try:
    cursor.execute("INSERT INTO your_table (column1, column2) VALUES (%s, %s)", (value1, value2))
    conn.commit()
except mysql.connector.Error as err:
    print(f"数据插入失败: {err}")
    conn.rollback()

import mysql.connector
import csv

# 数据库连接配置
db_config = {
    'host': 'your_host',
    'user': 'your_user',
    'password': 'your_password',
    'database': 'your_database'
}

# 文件路径
file_path = 'path/to/your/file.txt'

try:
    # 连接数据库
    conn = mysql.connector.connect(**db_config)
    cursor = conn.cursor()

    # 打开文件并读取数据
    with open(file_path, 'r') as file:
        reader = csv.reader(file, delimiter='\t')  # 根据实际情况调整分隔符
        for row in reader:
            if len(row) != expected_columns:
                print(f"数据格式错误: {row}")
                continue
            # 插入数据
            cursor.execute("INSERT INTO your_table (column1, column2) VALUES (%s, %2)", (row[0], row[1]))
    
    # 提交事务
    conn.commit()
except mysql.connector.Error as err:
    print(f"数据库操作失败: {err}")
    conn.rollback()
finally:
    # 关闭连接
    cursor.close()
    conn.close()