Импорт данных Python SQL - удалена обратная косая черта в процессе импорта данных в базу данных - PullRequest
Новая
       29

Импорт данных Python SQL - удалена обратная косая черта в процессе импорта данных в базу данных

0 голосов
/ 06 мая 2018

Я импортирую в базу данных строковые значения, проблема в том, что в процессе импорта удаляются обратные слеши. Так, где у меня было "\\" в базе данных, появляется следующее "\", и где у меня было "\", я получаю "". Любая помощь очень ценится.

Код метода импорта: 

         cnxn = MySQLdb.connect(host=entry_server_value, user=entry_user_value, passwd=entry_password_value, db=entry_dbName_value)
    columns_list = ""
    for column in columns:
        columns_list = columns_list + column
        if columns.index(column) is not (len(columns)-1):
            columns_list = columns_list + ','

    for line in csv.reader(open(full_file_path)):
        cursor = cnxn.cursor()
        values = ""
        for x in line:
            values = values + "'" + str(x) + "'"
            if line.index(x) is not (len(line)-1):
                values = values + ','

        # In case last character is comma remove 
        if values[-1:] is ',':
            values = values[:-1]

        mysql_q = 'SET SQL_SAFE_UPDATES = 0;insert into ' + entry_dbName_value + '.' + file_name + \
              ' (' + columns_list + ') VALUES(' + values + ');SET SQL_SAFE_UPDATES = 1;'
        cursor.execute("%r"%mysql_q)
        cursor.close()
        cnxn.commit()

1 Ответ

0 голосов
/ 13 мая 2018

MySQLdb (и другие пакеты, соответствующие стандарту DB-API Python) предоставляет метод подстановки параметров, который обеспечивает автоматическое экранирование строк. Лучше использовать это, чем пытаться вручную создать значения для вставки (это также безопаснее, если вы вставляете данные из ненадежного источника).

Для MySQLdb строка подстановки - "% s".

Вы создаете утверждение следующим образом:

stmt = """INSERT INTO mytable (col1, col2) VALUES (%s, %s);"""

И выполнить так:

cursor.execute(stmt, ('foo', 'bar'))

или вы можете вставить несколько строк в один оператор:

cursor.executemany(stmt, [('foo', 'bar'), ('baz', 'quux')])

Ваш код должен выглядеть примерно так: 

mysql_q = 'SET SQL_SAFE_UPDATES = 0;insert into ' + entry_dbName_value + '.' + file_name + \
          ' (' + columns_list + ') VALUES({});SET SQL_SAFE_UPDATES = 1;'
for line in csv.reader(open(full_file_path)):
    cursor = cnxn.cursor()
    subs = ','.join('%s' for _ in line)
    stmt = mysql_q.format(subs)
    cursor.execute(stmt, line)
    cursor.close()
    cnxn.commit()
...