Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MyFuncGlobalTransaction ¶
MyFuncGlobalTransaction zorm适配seata/hptx 全局分布式事务的函数 重要!!!!需要配置zorm.DataSourceConfig.FuncGlobalTransaction=MyFuncGlobalTransaction 重要!!!
Types ¶
type CustomDMText ¶
type CustomDMText struct{}
实现CustomDriverValueConver接口,扩展自定义类型,例如 达梦数据库text类型,映射出来的是dm.DmClob类型,无法使用string类型直接接收
func (CustomDMText) ConverDriverValue ¶
func (dmtext CustomDMText) ConverDriverValue(columnType *sql.ColumnType, structFieldType *reflect.Type, tempDriverValue driver.Value, finder *zorm.Finder) (interface{}, error)
ConverDriverValue 数据库列类型,实体类属性类型,GetDriverValue返回的driver.Value的临时接收值,Finder对象 如果无法获取到structFieldType,例如Map查询,会传入nil 返回符合接收类型值的指针,指针,指针!!!!
func (CustomDMText) GetDriverValue ¶
func (dmtext CustomDMText) GetDriverValue(columnType *sql.ColumnType, structFieldType *reflect.Type, finder *zorm.Finder) (driver.Value, error)
GetDriverValue 根据数据库列类型,实体类属性类型,Finder对象,返回driver.Value的实例 如果无法获取到structFieldType,例如Map查询,会传入nil 如果返回值为nil,接口扩展逻辑无效,使用原生的方式接收数据库字段值
type IGlobalTransaction ¶
type IGlobalTransaction interface {
// Begin 开启全局分布式事务
Begin(ctx context.Context) error
// Commit 提交全局分布式事务
Commit(ctx context.Context) error
// Rollback 回滚全局分布式事务
Rollback(ctx context.Context) error
// GetXID 获取全局分布式事务的XID
GetXID(ctx context.Context) string
}
IGlobalTransaction 托管全局分布式事务接口,seata和hptx目前实现代码一致,只是引用的实现包不同
type ZormGlobalTransaction ¶
type ZormGlobalTransaction struct {
*tm.DefaultGlobalTransaction
}
ZormGlobalTransaction 包装seata/hptx的*tm.DefaultGlobalTransaction,实现zorm.IGlobalTransaction接口
func (*ZormGlobalTransaction) Begin ¶
func (gtx *ZormGlobalTransaction) Begin(ctx context.Context) error
实现zorm.IGlobalTransaction 托管全局分布式事务接口,seata和hptx目前实现代码一致,只是引用的实现包不同 Begin 开启全局分布式事务
func (*ZormGlobalTransaction) Commit ¶
func (gtx *ZormGlobalTransaction) Commit(ctx context.Context) error
Commit 提交全局分布式事务
Source Files