Запись csv-файла в базу данных SQL Server с использованием python
Привет, Я пытаюсь написать файл csv в таблицу в базе данных SQL Server с помощью python. Я сталкиваюсь с ошибками при передаче параметров, но я не сталкиваюсь с какой-либо ошибкой, когда делаю это вручную. Вот код, который я выполняю.
cur=cnxn.cursor() # Get the cursor csv_data = csv.reader(file(Samplefile.csv')) # Read the csv for rows in csv_data: # Iterate through csv cur.execute("INSERT INTO MyTable(Col1,Col2,Col3,Col4) VALUES (?,?,?,?)",rows) cnxn.commit() Ошибка: pyodbc.DataError: ('22001', '[22001] [Microsoft] [ODBC SQL Server Driver] [SQL Server] Строковые или двоичные данные будут усечены. (8152) (SQLExecDirectW); [01000] [Microsoft] [ ODBC SQL Server Driver] [SQL Server] Оператор завершен. (3621) ')
Однако, когда я вставляю значения вручную. Он отлично работает
cur.execute("INSERT INTO MyTable(Col1,Col2,Col3,Col4) VALUES (?,?,?,?)",'A','B','C','D')
Я убедился, что ТАБЛИЦА существует в базе данных, типы данных соответствуют данным, которые я передаю. Соединение и курсор также верны. Тип данных строк – «список»,
3 Solutions collect form web for “Запись csv-файла в базу данных SQL Server с использованием python”
Подумайте о построении запроса динамически, чтобы убедиться, что количество заполнителей соответствует вашей таблице и формату файла CSV. Тогда просто вопрос обеспечения правильности таблицы и CSV-файла, а не проверки того, что вы набрали достаточно ? заполнители в вашем коде.
Следующий пример предполагает
- CSV-файл содержит имена столбцов в первой строке
- Соединение уже построено
- Имя файла –
test.csv - Имя таблицы –
MyTable - Python 3
... with open ('test.csv', 'r') as f: reader = csv.reader(f) columns = next(reader) query = 'insert into MyTable({0}) values ({1})' query = query.format(','.join(columns), ','.join('?' * len(columns))) cursor = connection.cursor() for data in reader: cursor.execute(query, data) cursor.commit()
Если имена столбцов не включены в файл:
... with open ('test.csv', 'r') as f: reader = csv.reader(f) data = next(reader) query = 'insert into dbo.Test values ({0})' query = query.format(','.join('?' * len(data))) cursor = connection.cursor() cursor.execute(query, data) for data in reader: cursor.execute(query, data) cursor.commit()
Пробовали ли вы передавать столбцы в качестве аргументов, например
for rows in csv_data: # Iterate through csv cur.execute("INSERT INTO MyTable(Col1,Col2,Col3,Col4) VALUES (?,?,?,?)", *rows)
Спасибо всем, я разобрался. Ошибка была вызвана ограничением ограничения размера таблицы. Он изменил емкость столбца, например, от col1 varchar (10) до col1 varchar (35) и т. Д. Теперь он работает отлично.
@beargle: Мне очень понравился ваш способ программирования