scala slick mysql utf8mb4 支持

语言  scala 

sql包  slick 3.2.0

数据库  mysql

 

数据库同步程序报错

java.sql.SQLException: Incorrect string value: \xF0\x9F\x87\xB5\xF0\x9F... for column content at row 1

 

这个错误见的太多,emoji字符和utf-8不兼容所致,utf8mp4字符集支持emoji

 

源库(另外一家公司提供)改了表的字符集,未通知我方,从库和源库字符集不同,同步时部分字符报错

 

改mysql,改同步程序字符集即可

 

改mysql简单

ALTER TABLE table CONVERT TO CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;

 

同步服务用scala实现,引用的slick

 

slick比较小众 改utf8mb4全网都没什么资料,不过思路和传统java项目一致

 

官方配置若无相关参数,也有ini办法解决,因此有两种方式

原连接方式为

val DEST_DB = Database.forURL("jdbc:mysql://127.0.0.1:3306/table?characterEncoding=UTF-8&charset=utf8mb4", user = "root", password = "123456", driver = "com.mysql.jdbc.Driver")

解决方式两种

1 手动run 执行ini语句

val DEST_DB = Database.forURL("jdbc:mysql://127.0.0.1:3306/table?characterEncoding=UTF-8&charset=utf8mb4", user = "root", password = "123456", driver = "com.mysql.jdbc.Driver")ORIGIN_DB.run(sql"""SET NAMES utf8mb4 COLLATE utf8mb4_unicode_ci""".as[Int])

 

2 通过jdbc ini 实始化

val ORIGIN_DB = Database.forURL("jdbc:mysql://127.0.0.1:3306/table?charset=utf8mb4;INIT=\"SET NAMES utf8mb4 COLLATE utf8mb4_unicode_ci\"", user = "root", password = "123456", driver = "com.mysql.jdbc.Driver",executor = AsyncExecutor("orgindb", minThreads=1, queueSize=10,maxThreads=10,maxConnections=10),keepAliveConnection=true)

 

 

相关文章