登录/ 注册
 找回密码
 立即注册
关闭

CSDN热搜

程序园 精品问答 技术交流 资源下载
返回列表 发新帖
首页 › 业界区 › 业界 ›Go工程选择开源分库分表中间件可用性测试 ...

Go工程选择开源分库分表中间件可用性测试

鄂缮输 前天 21:51
近期在寻找Go工程可以用的开源分库分表中间件，找了3个：ShardingSphere-Proxy，Kingshard，Gaea，下面给出测试过程和对比结果
ShardingSphere-Proxy

https://github.com/apache/shardingsphere
有apache基金会支持，社区活跃, star 20.2k
Kingshard

https://github.com/flike/kingshard
个人项目, github已经不更新了，star 6.4k
Gaea

https://github.com/XiaoMi/Gaea
小米团队发布，最近更新是2024年9月，还算比较新，star 2.7k
分表设置

t_user 分10个表
sharding-proxy是 t_user_0...9
kingshard和Gaea是 t_user_0000...0009
测试代码
  1. package main
  3. import (
  4.         "database/sql"
  5.         "encoding/json"
  6.         "fmt"
  7.         "math/rand"
  8.         "sharding/internal/models"
  9.         "strings"
  10.         _ "github.com/go-sql-driver/mysql" // 导入 MySQL 驱动
  11.         "log"
  12. )
  14. const (
  15.         // 定义颜色的 ANSI 转义序列
  16.         Reset  = "\033[0m"
  17.         Red    = "\033[31m"
  18.         Green  = "\033[32m"
  19.         Yellow = "\033[33m"
  20.         Blue   = "\033[34m"
  21. )
  23. func main() {
  25.         log.Println(Red + "shardingsphere-proxy test" + Reset)
  26.         dsn_proxy := "sharding:sharding@tcp(127.0.0.1:13308)/sharding_user?charset=utf8mb4&parseTime=True&loc=Local"
  27.         sharding_query(dsn_proxy)
  29.         log.Println(Yellow + "kingshard test" + Reset)
  30.         dsn_kingshard := "kingshard:kingshard@tcp(127.0.0.1:9696)/sharding_user?charset=utf8mb4&parseTime=True&loc=Local"
  31.         sharding_query(dsn_kingshard)
  33.         log.Println(Blue + "gaea test" + Reset)
  34.         dsn_gaea := "sharding_gaea:sharding_gaea@tcp(127.0.0.1:13306)/sharding_user?charset=utf8mb4&parseTime=True&loc=Local"
  36.         sharding_query(dsn_gaea)
  37. }
  39. func sharding_query(dsn string) {
  41.         //sharding proxy
  43.         shardingProxyConn, err := sql.Open("mysql", dsn)
  44.         if err != nil {
  45.                 log.Println(err)
  46.                 return
  47.         }
  48.         defer shardingProxyConn.Close()
  50.         id := rand.Intn(10)
  51.         userName := fmt.Sprintf("test%d", id)
  52.         notFound := false
  54.         // 完整sql,无传参
  55.         var uid uint64
  56.         valScope := strings.ReplaceAll(userName, "'", "\\'")
  57.         err = shardingProxyConn.QueryRow(fmt.Sprintf("select id from t_user where login_name = '%s'", valScope)).Scan(&uid)
  58.         if err != nil {
  59.                 if err == sql.ErrNoRows {
  60.                         log.Println("query 1 fail 1: ", err.Error())
  61.                         notFound = true
  62.                 } else {
  63.                         log.Println("query 1 fail 2:", err)
  64.                 }
  65.         } else {
  66.                 log.Println("query 1 success, uid=", uid)
  67.         }
  69.         // sql传参
  70.         err = shardingProxyConn.QueryRow("select id from t_user where login_name = ?", userName).Scan(&uid)
  71.         if err != nil {
  72.                 if err == sql.ErrNoRows {
  73.                         log.Println("query 2 fail 1: ", err.Error())
  74.                         notFound = true
  75.                 } else {
  76.                         log.Println("query 2 fail 2:", err)
  77.                 }
  78.         } else {
  79.                 log.Println("query 2 success, uid=", uid)
  80.         }
  81.         // create
  82.         if notFound {
  83.                 // sharding-proxy 有 id 自动生成配置,这里方便测试需要，指定id
  84.                 sqlIns := "INsert into t_user (id, login_name,passwd,email) values (?, ?, ?, ?)"
  85.                 result, err1 := shardingProxyConn.Exec(sqlIns, id, userName, "test1234", "test@test.com")
  86.                 if err1 != nil {
  87.                         log.Println("insert fail:", err1)
  88.                 } else {
  89.                         rowsAffected, _ := result.RowsAffected()
  90.                         log.Println("insert RowsAffected ", rowsAffected)
  91.                 }
  92.         }
  94.         //Select
  96.         rows, err := shardingProxyConn.Query("select id,login_name,email,create_time,update_time from t_user where login_name like ? limit 10", "%test%")
  97.         if err != nil {
  98.                 log.Println(err)
  99.                 return
  100.         }
  101.         defer rows.Close()
  103.         var userList []models.UserModel
  104.         for rows.Next() {
  105.                 var u models.UserModel
  106.                 e := rows.Scan(&u.ID, &u.LoginName, &u.Email, &u.CreatedTime, &u.UpdateTime)
  107.                 if e != nil {
  108.                         log.Println("row scan err:", e)
  109.                         continue
  110.                 }
  111.                 userList = append(userList, u)
  112.         }
  113.         j, _ := json.Marshal(userList)
  114.         log.Println("select result:", string(j))
  115. }
复制代码
测试结论

shardingsphere-proxy 4.1


  • 分表查询不支持占位符传参，插曲：php测试过支持传参使用
  • 分表只支持全SQL
kingshard


  • 分表查询不支持占位符传参，插曲：php测试过支持传参使用
  • 分表查询支持全SQL
Gaea


  • 分表查询支持占位符传参
  • 分表查询支持全SQL
结论对比

Go代码的工程应用想用分库分表中间件，推荐次序
第1首选优先Gaea，因为支持占位符传参，github最近更新是2024年9月
第2是shardingsphere-proxy 4.1，因为不支持占位符传参，go工程想要用，就全得转换成完整SQL，但是配置比较简单，容易部署，有apache基金会支持，社区活跃
第3是kingshard，因为不支持占位符传参，就全得转换成完整SQL，并且github已经不更新了
测试结果日志
  1. 2025/04/19 17:04:24 shardingsphere-proxy test
  2. 2025/04/19 17:04:25 query 1 success, uid= 1119859588875681792
  3. [mysql] 2025/04/19 17:04:25 packets.go:64 [warn] unexpected seq nr: expected 4, got 5
  4. 2025/04/19 17:04:25 query 2 fail 2: commands out of sync. You can't run this command now
  5. [mysql] 2025/04/19 17:04:25 packets.go:64 [warn] unexpected seq nr: expected 8, got 17
  6. 2025/04/19 17:04:25 select result: null
  8. 2025/04/19 17:04:25 kingshard test
  9. 2025/04/19 17:04:25 query 1 success, uid= 4
  10. 2025/04/19 17:04:25 query 2 fail 2: Error 1105 (HY000): prepare error ERROR 1146 (42S02): Table 'sharding_user.t_user' doesn't exist
  11. 2025/04/19 17:04:25 Error 1105 (HY000): prepare error ERROR 1146 (42S02): Table 'sharding_user.t_user' doesn't exist
  13. 2025/04/19 17:04:25 gaea test
  14. 2025/04/19 17:04:25 query 1 fail 1:  sql: no rows in result set
  15. 2025/04/19 17:04:25 query 2 fail 1:  sql: no rows in result set
  16. 2025/04/19 17:04:25 insert RowsAffected  1
  17. 2025/04/19 17:04:25 select result: [{"created_time":"2025-04-19T00:51:23+08:00","update_time":"2025-04-19T00:51:23+08:00","id":1,"Email":"test@test.com","LoginName":"test1","Passwd":"","LoginStatus":0,"LastLoginTime":null,"LoginCount":0}...]
复制代码
来源：程序园用户自行投稿发布，如果侵权，请联系站长删除
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

使用道具 举报
相关推荐
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册
发帖
鄂缮输
前天 21:51

0

粉丝关注

4

主题发布

板块介绍填写区域，请于后台编辑
微信扫一扫