50 lines
934 B
Go
50 lines
934 B
Go
package rep
|
|
|
|
import (
|
|
"planA/initialization/golabl"
|
|
"planA/rep/i"
|
|
"planA/rep/impl/mysql"
|
|
"planA/rep/impl/sqlite"
|
|
)
|
|
|
|
type Db interface {
|
|
i.TaskExport
|
|
i.TaskRecords
|
|
}
|
|
|
|
// CreateDbFactoryWrite 创建写数据库工厂
|
|
// @return Db mysql写数据库
|
|
// @return Db sqlite写数据库
|
|
func CreateDbFactoryWrite() (Db, Db) {
|
|
return &mysql.GormAdapter{
|
|
DB: golabl.MysqlDb,
|
|
}, &sqLite.SqlAdapter{
|
|
DB: golabl.SqliteDb,
|
|
}
|
|
}
|
|
|
|
// CreateDbFactoryRead 创建读数据库工厂
|
|
// @return Db 读数据库
|
|
func CreateDbFactoryRead() Db {
|
|
var read Db
|
|
read = &mysql.GormAdapter{
|
|
DB: golabl.MysqlDb,
|
|
}
|
|
if golabl.Config.Server.ReadDb == "sqlite" {
|
|
read = &sqLite.SqlAdapter{
|
|
DB: golabl.SqliteDb,
|
|
}
|
|
}
|
|
return read
|
|
}
|
|
|
|
// CreateDbFactorySqliteRead 创建sqlite读数据库工厂
|
|
// @return Db 读数据库
|
|
func CreateDbFactorySqliteRead() Db {
|
|
var read Db
|
|
read = &sqLite.SqlAdapter{
|
|
DB: golabl.SqliteDb,
|
|
}
|
|
return read
|
|
}
|