@@ -177,9 +177,8 @@ def execute(self, query, args=None):
177
177
"""
178
178
del self .messages [:]
179
179
db = self ._get_db ()
180
- charset = db .character_set_name ()
181
180
if isinstance (query , unicode ):
182
- query = query .encode (charset )
181
+ query = query .encode (db . unicode_literal . charset )
183
182
if args is not None :
184
183
query = query % db .literal (args )
185
184
try :
@@ -225,8 +224,8 @@ def executemany(self, query, args):
225
224
del self .messages [:]
226
225
db = self ._get_db ()
227
226
if not args : return
228
- charset = db . character_set_name ()
229
- if isinstance ( query , unicode ): query = query .encode (charset )
227
+ if isinstance ( query , unicode ):
228
+ query = query .encode (db . unicode_literal . charset )
230
229
m = insert_values .search (query )
231
230
if not m :
232
231
r = 0
@@ -285,20 +284,19 @@ def callproc(self, procname, args=()):
285
284
"""
286
285
287
286
db = self ._get_db ()
288
- charset = db .character_set_name ()
289
287
for index , arg in enumerate (args ):
290
288
q = "SET @_%s_%d=%s" % (procname , index ,
291
289
db .literal (arg ))
292
290
if isinstance (q , unicode ):
293
- q = q .encode (charset )
291
+ q = q .encode (db . unicode_literal . charset )
294
292
self ._query (q )
295
293
self .nextset ()
296
294
297
295
q = "CALL %s(%s)" % (procname ,
298
296
',' .join (['@_%s_%d' % (procname , i )
299
297
for i in range (len (args ))]))
300
298
if type (q ) is UnicodeType :
301
- q = q .encode (charset )
299
+ q = q .encode (db . unicode_literal . charset )
302
300
self ._query (q )
303
301
self ._executed = q
304
302
if not self ._defer_warnings : self ._warning_check ()
0 commit comments