使用sqlalchemy和mysql插入unicode消息

我试图插入一个字符串，笑脸emojis到MySQL数据库中。我有以下测试引发异常。我如何克服这个错误？使用sqlalchemy和mysql插入unicode消息

下面是测试：

def test_write_unicode(self): 
    db_schema = "testing" 
    db_url = sqlalchemy.engine.url.URL(drivername='mysql', host=selah.db_host, 
     database=db_schema, 
     query={ 'read_default_file' : selah.db_config }) 
    db_eng = sqlalchemy.create_engine(name_or_url=db_url) 
    table_name = 'test_write_unicode' 
    db_eng.execute("DROP TABLE IF EXISTS {0}".format(table_name)) 
    db_eng.execute("CREATE TABLE {0} (message text) CHARACTER SET utf8mb4".format(table_name)) 

    wierd_message = u"It's all about jimmy from stater bros. " 
    db_eng.execute("INSERT INTO {} (message) VALUES (%s)".format(table_name), wierd_message)

这里是我的DB_CONFIG文件：

[mysqld] 
default-storage-engine=MyISAM 
[client] 
user=selah 
password=xxxx

以下是错误：

Error 
Traceback (most recent call last): 
    File "/home/selah/Code/selahwork/test_sqlalchemy.py", line 39, in test_write_unicode 
    db_eng.execute("INSERT INTO {} (message) VALUES (%s)".format(table_name), wierd_message) 
    File "/usr/lib/python2.7/dist-packages/sqlalchemy/engine/base.py", line 1614, in execute 
    return connection.execute(statement, *multiparams, **params) 
    File "/usr/lib/python2.7/dist-packages/sqlalchemy/engine/base.py", line 662, in execute 
    params) 
    File "/usr/lib/python2.7/dist-packages/sqlalchemy/engine/base.py", line 805, in _execute_text 
    statement, parameters 
    File "/usr/lib/python2.7/dist-packages/sqlalchemy/engine/base.py", line 874, in _execute_context 
    context) 
    File "/usr/lib/python2.7/dist-packages/sqlalchemy/engine/base.py", line 1027, in _handle_dbapi_exception 
    util.reraise(*exc_info) 
    File "/usr/lib/python2.7/dist-packages/sqlalchemy/engine/base.py", line 867, in _execute_context 
    context) 
    File "/usr/lib/python2.7/dist-packages/sqlalchemy/engine/default.py", line 324, in do_execute 
    cursor.execute(statement, parameters) 
    File "/usr/local/lib/python2.7/dist-packages/MySQLdb/cursors.py", line 187, in execute 
    query = query % tuple([db.literal(item) for item in args]) 
    File "/usr/local/lib/python2.7/dist-packages/MySQLdb/connections.py", line 278, in literal 
    return self.escape(o, self.encoders) 
    File "/usr/local/lib/python2.7/dist-packages/MySQLdb/connections.py", line 208, in unicode_literal 
    return db.literal(u.encode(unicode_literal.charset)) 
UnicodeEncodeError: 'latin-1' codec can't encode characters in position 39-41: ordinal not in range(256)

编辑：这是我成功的测试：）

def test_write_unicode(self): 
    db_schema = "testing" 
    db_url = sqlalchemy.engine.url.URL(drivername='mysql', host=selah.db_host, 
     database=db_schema, 
     query={ 'read_default_file' : selah.db_config, 'charset': 'utf8mb4' }) 
    db_eng = sqlalchemy.create_engine(name_or_url=db_url) 
    table_name = 'test_write_unicode' 
    db_eng.execute("DROP TABLE IF EXISTS {0}".format(table_name)) 
    db_eng.execute("CREATE TABLE {0} (message text) CHARACTER SET utf8mb4".format(table_name)) 

    wierd_message = u"It's all about jimmy from stater bros. " 
    db_eng.execute("INSERT INTO {} (message) VALUES (%s)".format(table_name), wierd_message) 
    res = db_eng.execute("SELECT * FROM {}".format(table_name)) 
    self.assertEqual(res.first()[0], wierd_message)

来源

2015-05-27 Selah

除了设置存储排序规则外，还需要告诉MySQL DBAPI使用UTF-8作为连接字符集。否则，MySQL通常默认为latin1_swedish_ci（ISO-8859-1）。

连接字符集是在使用connection string通常charset=utf8mb4设置，但我想象URL(query={'charset': 'utf8mb4'})大概也行。

来源

2015-05-27 20:17:25 bobince

使用sqlalchemy和mysql插入unicode消息

回答

相关问题