3

Python と MySQL コネクタを使用して、国勢調査データを (.csv ファイルから) mysql データベースに動的にロードしようとしています。

エラーが発生する理由がわかりません：

Traceback (most recent call last):
  File "miner.py", line 125, in <module>
    cursor.execute(add_csv_file, csv_info)
  File "/Library/Python/2.7/site-packages/mysql/connector/cursor.py", line 393, in execute
    self._handle_result(self._connection.cmd_query(stmt))
  File "/Library/Python/2.7/site-packages/mysql/connector/connection.py", line 586, in cmd_query
statement))
  File "/Library/Python/2.7/site-packages/mysql/connector/connection.py", line 508, in _handle_result
    raise errors.get_exception(packet)
mysql.connector.errors.ProgrammingError: 1064 (42000): You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near '/Users/afink/Documents/Research/Current Papers & Books/Youth Assessm' at line 1

実行前に出力された文字列は、同じユーザーの MySQL コマンドライン インターフェイスで正常に機能します。

簡単な問題のようですが、行き詰まっています。

def db_connect():
    config = {
        'user': 'username',
        'password': 'pass',
        'host': 'localhost',
        'database': 'uscensus',
        'raise_on_warnings': True,
    }

    from mysql.connector import errorcode
    try:
      cnx = mysql.connector.connect(**config)
      return cnx
    except mysql.connector.Error as err:
      if err.errno == errorcode.ER_ACCESS_DENIED_ERROR:
        print("Something is wrong with your user name or password")
      elif err.errno == errorcode.ER_BAD_DB_ERROR:
        print("Database does not exist")
      else:
        print(err)
    else:
      cnx.close()


cursor = cnx.cursor()

os.chdir("./")
for files in glob.glob("*.csv"):

    add_csv_file = ('''load data local infile '%(cwd)s/%(file_name)s' into table %(table_name)s 
                    columns terminated by ',' 
                    optionally enclosed by '\"'
                    escaped by '\"'
                    lines terminated by '\\n';''')

    # Insert CSV file information
    csv_info = {
        'cwd': os.getcwd(),
        'file_name': files,
        'table_name': 'SF1_' + files[2:-8],
    }


    print add_csv_file % csv_info # Temporary Debug

    cursor.execute(add_csv_file, csv_info)

# Make sure data is committed to the database
cnx.commit()
cursor.close()
cnx.close()

事前に助けてくれてありがとう！

4

4 に答える 4

2

This is easily solved with adding the appropriate client flag in your connection as below:

import mysql.connector
from mysql.connector.constants import ClientFlag

cnx = mysql.connector.connect(user='[username]', password='[pass]', host='[host]', client_flags=[ClientFlag.LOCAL_FILES])
cursor = cnx.cursor()

This will give permission for MySQL to access the local files on your machine and then the following LOAD will work: 

LoadSQL = """LOAD DATA LOCAL INFILE '%s'
    INTO TABLE %s
    FIELDS TERMINATED BY '\t'
    LINES TERMINATED BY '\n'
    IGNORE 1 LINES
    (field1, field2, field3, field4)""" % (csvfile, tabl_name)
cursor.execute(LoadSQL)
cnx.commit()
cursor.close()
cnx.close()
于 2014-08-25T23:28:11.150 に答える
1

さて、これが私が考え出したことです。

@Dd_tch - あなたの答えは、このコードがよりうまく機能することを理解するのに役立ちました:

query = add_csv_file % csv_info
cursor.execute(query)

コネクタのMySQLサイトは、私がしていたことを行うことができることを示しているようですが( http://dev.mysql.com/doc/connector-python/en/connector-python-example-cursor-transaction.html )、それはそうではありませんでした動作していません。

それを修正すると、新しいエラーが発生しました: mysql.connector.errors.ProgrammingError: 1148 (42000): The used command is not allowed with this MySQL version

MySQL コネクタ構成に「local_infile=1」を追加することでこれを修正できることを示すサイトがいくつかあります。これが1つです：http://dev.mysql.com/doc/refman/5.1/en/loading-tables.html

この解決策は私にはうまくいきませんでした。MySQL で local_infile が 1 に設定されていますが、Python コード内で設定できないか、または e

代わりに、LOAD LOCAL DATA INFILE を、CSV ファイルを 1 行ずつ読み取り、データベースに行を挿入するものに置き換えます。とにかく、これにより、コードが他の DB に移植しやすくなります。

于 2013-10-03T15:13:34.353 に答える
0

execute() メソッドを呼び出すときにエラーが発生しました。

cursor.execute(add_csv_file, csv_info)

試してみてください：

cursor.execute(クエリ、(add_csv_file、csv_info、))

于 2013-10-02T18:01:06.397 に答える