- update dorm

utils/dorm/bun.go

@@ -11,6 +11,6 @@ type ConfigBunClient struct {
 // BunClient
 // https://bun.uptrace.dev/
 type BunClient struct {
-	Db     *bun.DB          // 驱动
+	db     *bun.DB          // 驱动
 	config *ConfigBunClient // 配置
 }

utils/dorm/bun_get.go

@@ -0,0 +1,10 @@
+package dorm
+
+import (
+	"github.com/uptrace/bun"
+)
+
+// GetDb 获取驱动
+func (c *BunClient) GetDb() *bun.DB {
+	return c.db
+}

utils/dorm/bun_mysql.go

@@ -19,7 +19,7 @@ func NewBunMysqlClient(config *ConfigBunClient) (*BunClient, error) {
 		return nil, errors.New(fmt.Sprintf("加载驱动失败：%v", err))
 	}
 
-	c.Db = bun.NewDB(sqlDb, mysqldialect.New())
+	c.db = bun.NewDB(sqlDb, mysqldialect.New())
 
 	return c, nil
 }

utils/dorm/bun_postgresql.go

@@ -7,13 +7,13 @@ import (
 	"github.com/uptrace/bun/driver/pgdriver"
 )
 
-func NewBunPgsqlClient(config *ConfigBunClient) (*BunClient, error) {
+func NewBunPostgresqlClient(config *ConfigBunClient) (*BunClient, error) {
 
 	c := &BunClient{config: config}
 
 	sqlDb := sql.OpenDB(pgdriver.NewConnector(pgdriver.WithDSN(c.config.Dns)))
 
-	c.Db = bun.NewDB(sqlDb, pgdialect.New())
+	c.db = bun.NewDB(sqlDb, pgdialect.New())
 
 	return c, nil
 }

utils/dorm/upper.go

@@ -5,5 +5,5 @@ import "github.com/upper/db/v4"
 // UpperClient
 // https://upper.io/
 type UpperClient struct {
-	Db *db.Session // 驱动
+	db *db.Session // 驱动
 }

utils/dorm/upper_get.go

@@ -0,0 +1,10 @@
+package dorm
+
+import (
+	"github.com/upper/db/v4"
+)
+
+// GetDb 获取驱动
+func (c *UpperClient) GetDb() *db.Session {
+	return c.db
+}

utils/dorm/upper_mysql.go

@@ -17,7 +17,7 @@ func NewUpperMysqlClient(settings mysql.ConnectionURL) (*UpperClient, error) {
 	}
 	defer sess.Close()
 
-	c.Db = &sess
+	c.db = &sess
 
 	return c, nil
 }

utils/dorm/upper_postgresql.go

@@ -17,7 +17,7 @@ func NewUpperPostgresqlClient(settings postgresql.ConnectionURL) (*UpperClient,
 	}
 	defer sess.Close()
 
-	c.Db = &sess
+	c.db = &sess
 
 	return c, nil
 }

utils/dorm/zorm.go

@@ -12,6 +12,6 @@ type ConfigZormClient struct {
 // https://zorm.cn/
 // https://www.yuque.com/u27016943/nrgi00
 type ZormClient struct {
-	Db     *zorm.DBDao       // 驱动
+	db     *zorm.DBDao       // 驱动
 	config *ConfigZormClient // 配置
 }

utils/dorm/zorm_get.go

@@ -0,0 +1,10 @@
+package dorm
+
+import (
+	"gitee.com/chunanyong/zorm"
+)
+
+// GetDb 获取驱动
+func (c *ZormClient) GetDb() *zorm.DBDao {
+	return c.db
+}

utils/dorm/zorm_mysql.go

@@ -12,16 +12,10 @@ func NewZormMysqlClient(config *ConfigZormClient) (*ZormClient, error) {
 	var err error
 	c := &ZormClient{config: config}
 
-	c.Db, err = zorm.NewDBDao(&zorm.DataSourceConfig{
-		DSN:                   c.config.Dns,
-		DriverName:            "mysql", // 数据库驱动名称
-		DBType:                "mysql", // 数据库类型
-		PrintSQL:              true,    // 是否打印sql
-		MaxOpenConns:          0,       // 数据库最大连接数,默认50
-		MaxIdleConns:          0,       // 数据库最大空闲连接数,默认50
-		ConnMaxLifetimeSecond: 0,       // 连接存活秒时间. 默认600(10分钟)后连接被销毁重建.
-		// 避免数据库主动断开连接,造成死连接.MySQL默认wait_timeout 28800秒(8小时)
-		DefaultTxOptions: nil, // 事务隔离级别的默认配置,默认为nil
+	c.db, err = zorm.NewDBDao(&zorm.DataSourceConfig{
+		DSN:        c.config.Dns,
+		DriverName: "mysql", // 数据库驱动名称
+		Dialect:    "mysql", // 数据库类型
 	})
 	if err != nil {
 		return nil, errors.New(fmt.Sprintf("连接失败：%v", err))

utils/dorm/zorm_postgresql.go

@@ -12,16 +12,10 @@ func NewZormPostgresqlClient(config *ConfigZormClient) (*ZormClient, error) {
 	var err error
 	c := &ZormClient{config: config}
 
-	c.Db, err = zorm.NewDBDao(&zorm.DataSourceConfig{
-		DSN:                   c.config.Dns,
-		DriverName:            "postgres",   // 数据库驱动名称
-		DBType:                "postgresql", // 数据库类型
-		PrintSQL:              true,         // 是否打印sql
-		MaxOpenConns:          0,            // 数据库最大连接数,默认50
-		MaxIdleConns:          0,            // 数据库最大空闲连接数,默认50
-		ConnMaxLifetimeSecond: 0,            // 连接存活秒时间. 默认600(10分钟)后连接被销毁重建.
-		// 避免数据库主动断开连接,造成死连接.MySQL默认wait_timeout 28800秒(8小时)
-		DefaultTxOptions: nil, // 事务隔离级别的默认配置,默认为nil
+	c.db, err = zorm.NewDBDao(&zorm.DataSourceConfig{
+		DSN:        c.config.Dns,
+		DriverName: "postgres",   // 数据库驱动名称
+		Dialect:    "postgresql", // 数据库类型
 	})
 	if err != nil {
 		return nil, errors.New(fmt.Sprintf("连接失败：%v", err))