pythonでmysqlconnectorを使う際

Question

pythonでmysqlを操作して、日本語を取り出しその後それをcsvに書き込みたいのですが、
res = cursor.fetchall()
で取り出した後に、どこかで
.encode('cp932')
を行わないと文字化けしてしまうのでしたいのですが、タプルとリストはどちらも.encodeに対応していないというエラー内容が出てしまいました。
下記のようなプログラムで、.encode('cp932')をどのようにして組み込めば良いのでしょうか？
よろしくお願いします。
ちなみに一回のinsert_stmtで取り出す要素は複数個あります。(zz = 2 and aa = 2 and bb = 2に当てはまる a が複数あるため)

    user='root',
    password='',
    host='xxxx')
    cursor = connect.cursor()
    planname_lists = []
    for i in range(100):
        cursor = connect.cursor()
        insert_stmt = 'select a FROM aaaa WHERE zz = 2 and aa = 2 and bb = 2'
        cursor.execute(insert_stmt)
        res = cursor.fetchall()
        for k in range(len(res)):
            res[k] = list(res[k])
        connect.commit()
    cursor.close()
    connect.close()

Comments

[HidenoriYamano]

ちゃんとベストアンサー選ばないとダメだよこうちゃん！

Answer 1

cp932でなくとも、BOM付きUTF-8のcsvファイルを生成すれば文字化けしません。
cp932に変換できない文字の扱いを考えなくて済むので、お手軽です。
Pythonのマニュアル記述通りにコーディングすれば、以下の通りとなります。

まずは、Python-2.7系の場合です。

# -*- coding: utf-8 -*-
import codecs
import cStringIO
import csv
import mysql.connector

SQL_SEARCH = "SELECT name, price FROM item"

conn = mysql.connector.connect(
    user='root', password='', host='xxxx', db='database')
cursor = conn.cursor()
with open('test.csv', 'wb') as f:
    f.write(codecs.BOM_UTF8)    # BOMを書き込む
    csv_writer = UnicodeWriter(f)
    for name, price in cursor.execute(SQL_SEARCH):
        csv_writer.writerow([name, str(price)])


class UnicodeWriter:
    def __init__(self, f, dialect=csv.excel, encoding="utf-8", **kwds):
        self.queue = cStringIO.StringIO()
        self.writer = csv.writer(self.queue, dialect=dialect, **kwds)
        self.stream = f
        self.encoding = encoding

    def writerow(self, row):
        self.writer.writerow([s.encode("utf-8") for s in row])
        data = self.queue.getvalue()
        if isinstance(data, unicode):
            data = data.decode('utf-8').encode(self.encoding, 'replace')
        self.stream.write(data)
        self.queue.truncate(0)

    def writerows(self, rows):
        for row in rows:
            self.writerow(row)

次はPython3の場合。

# -*- coding: utf-8 -*-
import csv
import mysql.connector

SQL_SEARCH = "SELECT name, price FROM item"

conn = mysql.connector.connect(
    user='root', password='', host='xxxx', db='database')

cursor = conn.cursor()
with open('test.csv', 'w', newline='', encoding='utf-8-sig') as f:
    csv_writer = csv.writer(f)
    for name, price in cursor.execute(SQL_SEARCH):
        csv_writer.writerow([name, price])

Answer 2

ちゃんとベストアンサー選ばないとダメだよこうちゃん！

Answer 3

MySQLはUTF-8かなんかで、出力CSVをCP932にしたいということですよね？
であれば、codecs モジュールを使ってCSVを cp932 で開いてあげれば、あとは勝手にやってくれます。

import csv
import codecs

with codecs.open('hoge.csv', 'wb', 'cp932') as f:
    csv.writer(f).writerow(['ひらがな','カタカナ','漢字'])