gormManager

README

go-gorm-driver

import "github.com/qq1060656096/go-gorm-manager"

m := NewConnectionManager()
dataSourceName := "user:password@/dbname?charset=utf8&parseTime=True&loc=Local"
dataSourceName = fmt.Sprintf(
	"%s:%s@tcp(%s:%s)/%s?charset=utf8&parseTime=True&loc=Local",
	"root3",
	"root3",
	"199.199.199.199",
	"3306",
	"test1",
)
m.Add("test1", &ConnectionConfig{
	DatabaseDriverName: DRIVER_MY_SQL,
	DataSourceName: dataSourceName,
})

conn, err := m.Get("test1").GetGormDB()
if err == nil {
	sql := `insert test(nickname) values(?)`
    db := conn.Exec(sql, fmt.Sprintf("test1.field.value.%s", time.Now().Format("2006-01-02 15:04:05")))
}

# go test mysql sql
CREATE TABLE `test` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `nickname` varchar(128) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=utf8mb4;


# go test sqlite sql
CREATE TABLE "test" (
  "id" integer NOT NULL PRIMARY KEY AUTOINCREMENT,
  "nickname" text
);

Documentation

Index

• Constants
• type Connection
  • func (c *Connection) DisconnectGormDB() bool
  • func (c *Connection) GetGormDB() (*gorm.DB, error)
  • func (c *Connection) ReconnectGormDB() error
• type ConnectionConfig
• type ConnectionManager
  • func NewConnectionManager() *ConnectionManager
  • func (m *ConnectionManager) Add(name string, conf *ConnectionConfig)
  • func (m *ConnectionManager) Exist(name string) bool
  • func (m *ConnectionManager) Get(name string) *Connection
  • func (m *ConnectionManager) Length() int
  • func (m *ConnectionManager) Remove(name string)
  • func (m ConnectionManager) String() string

Constants

const (
	DRIVER_MY_SQL      = "mysql"
	DRIVER_POSTGRE_SQL = "postgres"
	DRIVER_SQLITE3     = "sqlite3"
	DRIVER_SQL_SERVER  = "mssql"
)

Types

type Connection

type Connection struct {
	// contains filtered or unexported fields
}

func (*Connection) DisconnectGormDB

func (c *Connection) DisconnectGormDB() bool

func (*Connection) GetGormDB

func (c *Connection) GetGormDB() (*gorm.DB, error)

func (*Connection) ReconnectGormDB

func (c *Connection) ReconnectGormDB() error

type ConnectionConfig

type ConnectionConfig struct {
	DatabaseDriverName string
	DataSourceName     string
}

type ConnectionManager

type ConnectionManager struct {
	// contains filtered or unexported fields
}

func NewConnectionManager

func NewConnectionManager() *ConnectionManager

func (*ConnectionManager) Add

func (m *ConnectionManager) Add(name string, conf *ConnectionConfig)

func (*ConnectionManager) Exist

func (m *ConnectionManager) Exist(name string) bool

func (*ConnectionManager) Get

func (m *ConnectionManager) Get(name string) *Connection

func (*ConnectionManager) Length

func (m *ConnectionManager) Length() int

func (*ConnectionManager) Remove

func (m *ConnectionManager) Remove(name string)

func (ConnectionManager) String

func (m ConnectionManager) String() string