Skip to content
This repository was archived by the owner on Feb 13, 2026. It is now read-only.

Commit fdb3fbd

Browse files
author
dfcao
committed
fix: process set field type
1 parent 3f32862 commit fdb3fbd

2 files changed

Lines changed: 11 additions & 7 deletions

File tree

README.md

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -13,11 +13,11 @@ binlog2sql
1313

1414
项目状态
1515
===
16-
正常维护。应用于部分公司线上环境。线上环境的操作,请在对MySQL**相当熟悉**的同学指导下进行
16+
正常维护。应用于部分公司线上环境。
1717

1818
* 已测试环境
19-
* Python 2.6, 2.7, 3.4
20-
* MySQL 5.6
19+
* Python 2.7, 3.4+
20+
* MySQL 5.6, 5.7
2121

2222

2323
安装
@@ -217,14 +217,16 @@ Empty set (0.00 sec)
217217
218218
### 贡献者
219219
220-
* danfengcao 作者,维护者 [https://github.com/danfengcao](https://github.com/danfengcao)
220+
* [danfengcao](https://github.com/danfengcao) 作者,维护者 [https://github.com/danfengcao]
221221
* 大众点评DBA团队 想法交流,使用体验
222-
* 赵承勇 pymysqlreplication权限bug [https://github.com/imzcy1987](https://github.com/imzcy1987)
223-
* 陈路炳 bug报告(字段值为空时的处理),使用体验 [https://github.com/bingluchen](https://github.com/bingluchen)
222+
* [赵承勇](https://github.com/imzcy1987) pymysqlreplication权限bug #2
223+
* [陈路炳](https://github.com/bingluchen) bug报告(字段值为空时的处理),使用体验
224+
* [dba-jane](https://github.com/DBA-jane) pymysqlreplication时间字段浮点数bug #29
225+
* [lujinke](https://github.com/lujinke) bug报告(set字段的处理 #32)
224226
225227
### 联系我
226228
227-
有任何问题,请与我联系。微信:danfeng053005 邮箱:[danfengcao.info@gmail.com](danfengcao.info@gmail.com)
229+
有任何问题,请与我联系。邮箱:[danfengcao.info@gmail.com](danfengcao.info@gmail.com)
228230
229231
欢迎提问题提需求,欢迎pull requests!
230232

binlog2sql/binlog2sql_util.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -130,6 +130,8 @@ def compare_items(items):
130130

131131
def fix_object(value):
132132
"""Fixes python objects so that they can be properly inserted into SQL queries"""
133+
if isinstance(value, set):
134+
value = ','.join(value)
133135
if PY3PLUS and isinstance(value, bytes):
134136
return value.decode('utf-8')
135137
elif not PY3PLUS and isinstance(value, unicode):

0 commit comments

Comments
 (0)