У меня есть URL-адрес со строками запроса, через которые передаются некоторые данные. Я хочу получить данные на стороне сервера. import sys импорт csv dbServer = 'localhost' dbPass = 'суперсекретный пароль' dbSchema = 'dbTest' dbUser = 'root' dbQuery = 'ВЫБРАТЬ * ИЗ pbTest.Orders;' db = ...
У меня есть следующее:
import MySQLdb as dbapi
import sys
import csv
dbServer='localhost'
dbPass='supersecretpassword'
dbSchema='dbTest'
dbUser='root'
dbQuery='SELECT * FROM pbTest.Orders;'
db=dbapi.connect(host=dbServer,user=dbUser,passwd=dbPass)
cur=db.cursor()
cur.execute(dbQuery)
result=cur.fetchall()
c = csv.writer(open("temp.csv","wb"))
c.writerow(result)
Это приводит к искаженному беспорядку. Я знаком с использованием записи для печати [0] и т. Д. Не уверен, что мне следует делать с настройкой форматирования. чтобы создать что-то вроде запроса в консоли. Я не могу сделать простой INTO OUTFILE с сервера mysql.
Обновление
Прошло 8 лет; Я все еще время от времени получаю обновления или запросы по этому вопросу.
Как указано в некоторых комментариях, cursor.description из DBAPI - это то, что я искал.
Вот еще современный пример на Python 3 с использованием драйвера pymysql для подключения к MariaDB , который будет выбирать и извлекать все строки в кортеж, заголовки / описание строк в список. Затем я объединяю эти две структуры данных в один список для записи в файл csv .
Имена заголовков являются первой записью в списке результатов; запись результата в файл в линейном режиме гарантирует, что заголовок строки будет первой строкой в файле CSV.
import pymysql
import csv
import sys
db_opts = {
'user': 'A',
'password': 'C',
'host': 'C',
'database': 'D'
}
db = pymysql.connect(**db_opts)
cur = db.cursor()
sql = 'SELECT * from schema_name.table_name where id=123'
csv_file_path = '/tmp/my_csv_file.csv'
try:
cur.execute(sql)
rows = cur.fetchall()
finally:
db.close()
# Continue only if there are rows returned.
if rows:
# New empty list called 'result'. This will be written to a file.
result = list()
# The row name is the first entry for each entity in the description tuple.
column_names = list()
for i in cur.description:
column_names.append(i[0])
result.append(column_names)
for row in rows:
result.append(row)
# Write result to file.
with open(csv_file_path, 'w', newline='') as csvfile:
csvwriter = csv.writer(csvfile, delimiter=',', quotechar='"', quoting=csv.QUOTE_MINIMAL)
for row in result:
csvwriter.writerow(row)
else:
sys.exit("No rows found for query: {}".format(sql))
Я немного знаю Python, но после небольшого поиска в Google, вы должны использовать Writerows (с S), который записывает несколько строк, а не Writerow, который ожидает одну строку.
Как я уже сказал, это немного укол в темноте от меня.
import pymysql
import sys
import csv
connection = pymysql.connect(host='abcde',
user='admin',
password='secret',
db='databaseName',
port=12345)
dbQuery="SELECT field1, field2, fieldn FROM database.table;"
cur=connection.cursor()
cur.execute(dbQuery)
rows=cur.fetchall()
column_names = [i[0] for i in cur.description]
fp = open('DimDevice.csv', 'w')
myFile = csv.writer(fp, lineterminator = '\n')
myFile.writerow(column_names)
myFile.writerows(rows)
fp.close()