DTM开源项目文档SDK
支持的语言
go
这里的client都是dtm/client里面内容的同步复制。采用这里的包，而不是dtm，会让你的应用程序依赖更少，包体更小
client: https://github.com/dtm-labs/client
最简示例: https://github.com/dtm-labs/quick-start-sample
关于SDK使用的最全的示例，包括了grpc/http/xa/msg/saga/tcc/barrier 等等，都合并在下面这个项目
https://github.com/dtm-labs/dtm-examples
php
客户端sdk 协程版（支持Hyperf、SAGA、TCC、MSG、XA、子事务屏障）https://github.com/dtm-php/dtm-client
示例：https://github.com/dtm-php/dtm-sample
上述SDK由PHP界大佬黄朝晖发起，并亲自操刀设计，主要代码由PandaLIU-1111贡献，并获得Swoole创始人推荐，代码质量高，社区活跃
普通版客户端sdk（当前只支持TCC）: https://github.com/dtm-labs/dtmcli-php
示例: https://github.com/dtm-labs/dtmcli-php-sample
感谢 onlyshow 的帮助，php的sdk和示例，主要由他完成
dotnet
客户端sdk http版本（支持TCC、SAGA、MSG、子事务屏障）: https://github.com/dtm-labs/dtmcli-csharp
示例: https://github.com/dtm-labs/dtmcli-csharp-sample
感谢 catcherwong、geffzhang的帮助，C#的sdk和示例，主要由他们贡献
客户端sdk grpc版本：https://github.com/catcherwong/dtmgrpc-csharp
python
客户端sdk（当前支持TCC、SAGA、子事务屏障）: https://github.com/dtm-labs/dtmcli-py
示例: https://github.com/dtm-labs/dtmcli-py-sample
Java
客户端sdk（SAGA、TCC、子事务屏障）: https://github.com/dtm-labs/dtmcli-java
示例: https://github.com/dtm-labs/dtmcli-java-sample
感谢 li-xiao-shuang，viticis Kui Liao的帮助，Java的sdk和示例，主要由他们贡献
node
客户端sdk（当前只支持TCC）: https://github.com/dtm-labs/dtmcli-node
示例: https://github.com/dtm-labs/dtmcli-node-sample
其他
如果这里没有找到您熟悉的语言，同时您又想运行dtm，看看一个分布式事务什么样，您可以参考这里：
如果你是通过brew 安装，那么您可以直接运行
dtm-qs
上述dtm-qs命令，会运行一个简单的quick start例子，这是一个saga事务，您可以对照saga的时序图与日志，更深入的了解dtm
支持的数据库
dtm的SDK中，提供了子事务屏障功能，也提供了XA相关的支持，这部分的支持是与具体的数据库相关的。目前已支持了常见的几种数据库事务，包括Mysql系列、Postgres，Redis、Mongo。未来将考虑接入更多的数据库事务
Mysql 系列
包括Mysql，MariaDB，TiDB，TDSQL
Postgres
已完整支持Postgres，如果您使用Postgres，需要在使用SDK前，进行如下调用
dtmcli.SetCurrentDBType("postgres")
详细例子，可以参考dtm/app/main.go中的代码
Redis
DTM 已支持 Redis 事务，这样用户可以在一个分布式事务里，组合使用 Redis 及 Mysql ，可以将扣库存放在 Redis 中，提供准确扣库存的架构，让订单系统可以轻松应对秒杀场景
Mongo
DTM已支持Mongo
ORM 对接
概述
dtm中的子事务屏障，需要与数据库交互，xa事务模式，也需要与数据库交互。目前dtm定义的交互接口，采用了与标准库sql兼容的方式，使用中，直接传递sql.DB/sql.Tx即可。
因为barrier需要在事务内部操作barrier相关的表，所以它的接口需要传入一个 *sql.Tx或 *sql.DB
func (bb *BranchBarrier) Call(tx *sql.Tx, busiCall BusiFunc) error
func (bb *BranchBarrier) CallWithDB(db *sql.DB, busiCall BusiFunc) error
Xa事务模式中，本地数据库连接是由dtmcli创建和管理的，因此调用回调函数的参数类型是 *sql.DB 。如果您使用其他的库，例如gorm等，那么您根据 *sql.DB 构建相关的orm对象即可。
type XaLocalFunc func(db *sql.DB, xa *Xa) (interface{}, error)
目前 dtm 的示例，只给出了gorm的，其他orm，暂时在此说明文档中说明用法
GORM
示例在 dtm-examples
barrier示例：
barrier := MustBarrierFromGin(c)
// gdb is a *gorm.DB
tx := gdb.Begin()
return dtmcli.ResultSuccess, barrier.Call(tx.Statement.ConnPool.(*sql.Tx), func(tx1 *sql.Tx) error {
return tx.Exec("update dtm_busi.user_account set balance = balance + ? where user_id = ?", -req.Amount, 2).Error
})
xa示例：
return dtmcli.XaLocalTransaction(c.Request.URL.Query(), BusiConf, func(db *sql.DB, xa *dtmcli.Xa) error {
// gorm提供接口，可以从标准的sql.DB对象，构造gorm.DB
gdb, err := gorm.Open(mysql.New(mysql.Config{
Conn: db,
}), &gorm.Config{})
if err != nil {
return nil, err
}
dbr := gdb.Exec("update dtm_busi.user_account set balance=balance-? where user_id=?", reqFrom(c).Amount, 1)
return dbr.Error
})
GOQU
barrier示例：
dialect := goqu.Dialect("mysql")
sdb, err := dbGet().DB.DB()
if err != nil {
return nil, err
}
gdb := dialect.DB(sdb)
// gdb is a goqu dialect.DB, the following code shows how to obtain tx
tx, err := gdb.Begin()
return dtmcli.ResultSuccess, barrier.Call(tx, func(tx1 *sql.Tx) error {
_, err := tx.Exec("update dtm_busi.user_account set balance = balance + ? where user_id = ?", -req.Amount, 2)
return err
})
xa示例
return dtmcli.XaLocalTransaction(c.Request.URL.Query(), BusiConf, func(db *sql.DB, xa *dtmcli.Xa) error {
dialect := goqu.Dialect("mysql")
godb := dialect.DB(db)
_, err := godb.Exec("update dtm_busi.user_account set balance=balance-? where user_id=?", reqFrom(c).Amount, 1)
return err
})
XORM
请注意，2021-08-21刚给xorm提了pr，暴露了sql.Tx，虽然已合并，但是还未发布版本，因此需要安装最新版本
go get -u xorm.io/xorm@7cd6a74c9f
barrier示例：
x, _ := xorm.NewEngineWithDB("mysql", "dtm", core.FromDB(sdbGet()))
se := x.NewSession()
defer se.Close()
err := se.Begin()
if err != nil {
return nil, err
}
// se is a xorm session, the following code shows how to obtain tx
return dtmcli.ResultSuccess, barrier.Call(se.Tx().Tx, func(tx1 *sql.Tx) error {
_, err := se.Exec("update dtm_busi.user_account set balance = balance + ? where user_id = ?", -req.Amount, 2)
return err
})
xa示例
return dtmcli.XaLocalTransaction(c.Request.URL.Query(), BusiConf, func(db *sql.DB, xa *dtmcli.Xa) error {
xdb, _ := xorm.NewEngineWithDB("mysql", "dtm", core.FromDB(db))
_, err := xdb.Exec("update dtm_busi.user_account set balance=balance-? where user_id=?", reqFrom(c).Amount, 1)
return err
})
Go-zero
需要go-zero >= v1.2.0
barrier示例：
// 假设conn为go-zero里面的 sqlx.SqlConn
db, err := conn.RawDB()
if err != nil {
return err
}
return dtmcli.ResultSuccess, barrier.CallWithDB(db, func(tx *sql.Tx) error {
_, err := tx.Exec("update dtm_busi.user_account set balance = balance + ? where user_id = ?", -req.Amount, 2)
return err
})
xa示例
return dtmcli.XaLocalTransaction(c.Request.URL.Query(), BusiConf, func(db *sql.DB, xa *dtmcli.Xa) error {
conn := NewSqlConnFromDB(db)
_, err := conn.Exec("update dtm_busi.user_account set balance=balance-? where user_id=?", reqFrom(c).Amount, 1)
return err
})
ent
可以支持，代码示例待补充