56

ここで何が欠けているのかわかりませんが、このコードはエラーメッセージなしで実行されますが、テーブルには何もありません。3列のCSV値をmysqlテーブルにロードしています

import csv
import MySQLdb

mydb = MySQLdb.connect(host='localhost',
    user='root',
    passwd='',
    db='mydb')
cursor = mydb.cursor()

csv_data = csv.reader(file('students.csv'))
for row in csv_data:

    cursor.execute('INSERT INTO testcsv(names, \
          classes, mark )' \
          'VALUES("%s", "%s", "%s")', 
          row)
#close the connection to the database.
cursor.close()
print "Done"

他の誰かが見ていただければ幸いです。

4

7 に答える 7

81

私はあなたがmydb.commit()すべての挿入をしなければならないと思います。

このようなもの

import csv
import MySQLdb

mydb = MySQLdb.connect(host='localhost',
    user='root',
    passwd='',
    db='mydb')
cursor = mydb.cursor()

csv_data = csv.reader(file('students.csv'))
for row in csv_data:

    cursor.execute('INSERT INTO testcsv(names, \
          classes, mark )' \
          'VALUES("%s", "%s", "%s")', 
          row)
#close the connection to the database.
mydb.commit()
cursor.close()
print "Done"
于 2012-04-14T15:11:44.340 に答える
16

pandasおよびsqlalchemyライブラリがない場合は、pipを使用してインストールしてください

pip install pandas
pip install sqlalchemy

pandasとsqlalchemyを使用して、データベースに直接挿入できます

import csv
import pandas as pd
from sqlalchemy import create_engine, types

engine = create_engine('mysql://root:*Enter password here*@localhost/*Enter Databse name here*') # enter your password and database names here

df = pd.read_csv("Excel_file_name.csv",sep=',',quotechar='\'',encoding='utf8') # Replace Excel_file_name with your excel sheet name
df.to_sql('Table_name',con=engine,index=False,if_exists='append') # Replace Table_name with your sql table name
于 2019-09-23T04:10:08.143 に答える
9

上記の答えは良さそうです。しかし、これを行う別の方法は、db接続とともに自動コミットオプションを追加することです。これにより、データベースで実行される他のすべての操作が自動的にコミットされ、sql.commit()毎回言及する必要がなくなります。

 mydb = MySQLdb.connect(host='localhost',
        user='root',
        passwd='',
        db='mydb',autocommit=true)
于 2018-07-04T09:49:16.990 に答える
4 
  from __future__ import print_function
import csv
import MySQLdb

print("Enter  File  To Be Export")
conn = MySQLdb.connect(host="localhost", port=3306, user="root", passwd="", db="database")
cursor = conn.cursor()
#sql = 'CREATE DATABASE test1'
sql ='''DROP TABLE IF EXISTS `test1`; CREATE TABLE test1 (policyID int, statecode varchar(255), county varchar(255))'''
cursor.execute(sql)

with open('C:/Users/Desktop/Code/python/sample.csv') as csvfile:
    reader = csv.DictReader(csvfile, delimiter = ',')
    for row in reader:
        print(row['policyID'], row['statecode'], row['county'])
        # insert
        conn = MySQLdb.connect(host="localhost", port=3306, user="root", passwd="", db="database")
        sql_statement = "INSERT INTO test1(policyID ,statecode,county) VALUES (%s,%s,%s)"
        cur = conn.cursor()
        cur.executemany(sql_statement,[(row['policyID'], row['statecode'], row['county'])])
        conn.escape_string(sql_statement)
        conn.commit()
于 2017-07-14T12:36:55.070 に答える
4

役立つ場合はpymsqlを使用する

import pymysql
import csv
db = pymysql.connect("localhost","root","12345678","data" )

cursor = db.cursor()
csv_data = csv.reader(open('test.csv'))
next(csv_data)
for row in csv_data:
    cursor.execute('INSERT INTO PM(col1,col2) VALUES(%s, %s)',row)

db.commit()
cursor.close()
于 2020-05-14T07:24:06.930 に答える
1

パンダのデータフレームの場合は、次のことができます。

データの送信

csv_data.to_sql=(con=mydb, name='<the name of your table>',
  if_exists='replace', flavor='mysql')

の使用を避けるためfor。

于 2016-10-08T15:26:52.337 に答える
0

最速の方法は、「loaddatainfile」ステートメントでMySQLバルクローダーを使用することです。これは、Pythonで思いつくどの方法よりもはるかに速い方法です。Pythonを使用する必要がある場合は、Python自体からステートメント「loaddatainfile」を呼び出すことができます。

于 2020-12-15T07:58:11.850 に答える