gogorm

README

go-db 数据操作

• https://www.topgoer.com/%E6%95%B0%E6%8D%AE%E5%BA%93%E6%93%8D%E4%BD%9C/
• 基于 https://github.com/go-gorm/gorm 的封装，更多用法到官方

目前已封装

• mysql
• sqlite3
• clickhouse
• postgresql
• sqlserver
• tidb

func testSqlite3() {
    err := gogorm.Init(gogorm.Config{
        DataSource: "./test.db",
        DBType:     gogorm.DATABASE_SQLITE,
    })
    if err != nil {
        golog.WithTag("godb").Error(err.Error())
        return
    }
    db := gogorm.Default().DB
    err = db.AutoMigrate(&Product{})
    if err != nil {
        golog.WithTag("godb").Error(err.Error())
        return
    }
    
    // Create
    insertProduct := &Product{Code: "D42", Price: 100}
    db.Insert(insertProduct)
    fmt.Println(insertProduct.ID)
    // Read
    var product Product
    tx := db.First(&product, 1) // find product with integer primary key
    if tx.Error != nil {
    fmt.Println("not found first ", tx.Error.Error())
    }
    db.First(&product, "code = ?", "D42")
    // Delete - delete product
    db.Delete(&product, 1)
    
    err = goutils.RemoveFile("./test.db")
    if err != nil {
        golog.WithTag("godb").Error(err.Error())
    }
}

func mysqlTest() {
    err := gogorm.Init(gogorm.Config{
        DataSource: "root:223238@tcp(127.0.0.1:33060)/gromdb?charset=utf8mb4&parseTime=True&loc=Localb",
    })
    if err != nil {
        golog.WithTag("godb").Error(err.Error())
        return
    }
    db := gogorm.Default().DB
	
	err = db.AutoMigrate(&Product{})
	if err != nil {
		golog.WithTag("godb").Error(err.Error())
		return
	}

	// Create
	insertProduct := &Product{Code: "D42", Price: 100}
	db.Insert(insertProduct)
	fmt.Println(insertProduct.ID)
	// Read
	var product Product
	tx := db.First(&product, 1) // find product with integer primary key
	if tx.Error != nil {
		fmt.Println("not found first ", tx.Error.Error())
	}
	db.First(&product, "code = ?", "D42")
	// Delete - delete product
	db.Delete(&product, 1)

}

func testClickhouse() {
	dsn := "tcp://localhost:9000?database=gorm&username=gorm&password=gorm&read_timeout=10&write_timeout=20"
    err := gogorm.Init(gogorm.Config{
        DataSource: dsn,
		DBType:     gogorm.DATABASE_CLICKHOUSE,
    })
	
    if err != nil {
        golog.WithTag("godb").Error(err.Error())
        return
    }
    db := gogorm.Default().DB
	
	err = db.Set("gorm:table_options", "ENGINE=Distributed(cluster, default, hits)").AutoMigrate(&Product{})
	if err != nil {
		golog.WithTag("godb").Error(err.Error())
		return
	}
	// Set table options

	// Create
	insertProduct := &Product{Code: "D42", Price: 100}
	db.Insert(insertProduct)
	fmt.Println(insertProduct.ID)
	// Read
	var product Product
	tx := db.First(&product, 1) // find product with integer primary key
	if tx.Error != nil {
		fmt.Println("not found first ", tx.Error.Error())
	}
	db.First(&product, "code = ?", "D42")
	// Delete - delete product
	db.Delete(&product, 1)
}

mongodb 不是关系性数据库 暂时不支持

Documentation

Index

• Constants
• func DelClient(names ...string)
• func Init(configs ...Config) (err error)
• type Config
• type GoGorm
  • func Default() *GoGorm
  • func GetClient(names ...string) *GoGorm
  • func New(config *Config) (*GoGorm, error)

Constants

const (
	DATABASE_MYSQL      = "mysql"
	DATABASE_POSTGRESQL = "postgres"
	DATABASE_SQLITE     = "sqlite"
	DATABASE_SQLSERVER  = "sqlserver"
	DATABASE_CLICKHOUSE = "clickhouse"
	DATABASE_TIDB       = "tidb"
)

Functions

func DelClient

func DelClient(names ...string)

func Init

func Init(configs ...Config) (err error)

Types

type Config

type Config struct {
	Name         string `yaml:"Name" json:"name,optional"`
	DBType       string `yaml:"DBType" json:"dbType,optional"` // default mysql
	DataSource   string `yaml:"DataSource" json:"dataSource,optional"`
	MaxIdleCount int    `yaml:"MaxIdleCount" json:"maxIdleCount,optional"` // zero means defaultMaxIdleConns; negative means 0
	MaxOpen      int    `yaml:"MaxOpen" json:"maxOpen,optional"`           // <= 0 means unlimited
	MaxLifetime  int    `yaml:"MaxLifetime" json:"maxLifetime,optional"`   // maximum amount of time a connection may be reused minutes
}

type GoGorm

type GoGorm struct {
	DB     *gorm.DB
	Config *Config
}

func Default

func Default() *GoGorm

func GetClient

func GetClient(names ...string) *GoGorm

func New

func New(config *Config) (*GoGorm, error)