README.md

database 数据库操作包

├── conf.go
├── dsl
├── kv
│   ├── redis
│   └── rocks
└── sql
    ├── conn.go       #数据连接
    ├── err.go        #define err
    ├── mysql.go      #mysql Driver
    └── pool.go       #连接池

这是一个数据库处理包

起初是有orm的设定，但因为在实际项目操作的过程中，orm不具备给DBA输出sql的能力所以放弃了。

使用该方法

Create Driver

    var config = &database.Config{
		Write: &database.DBConfig{
			DSN: "abel:123456@tcp(127.0.0.1:3306)/test?charset=utf8mb4&parseTime=true&loc=Local",
		},
		Read: []*database.DBConfig{
			{
				DSN: "abel:123456@tcp(127.0.0.1:3306)/test?charset=utf8mb4&parseTime=true&loc=Local",
			},
			{
				DSN: "abel:123456@tcp(127.0.0.1:3306)/test?charset=utf8mb4&parseTime=true&loc=Local",
			},
		},
		DefIdleTimeout: 200,
		DefMaxIdle:     10,
		DefMaxActive:   20,
	}
	conns := NewMySQLPool(config)
    

获得一个数据或多个数据

Fetch 获取的结果均以map[string]interface{} 或者 []map[string]interface{} 类型返回
FetchOne 只会获得查询结果的第一条记录

    db := conns.Slave() //获得读库链接 
    user, err := db.Prepared("SELECT * FROM users").FetchOne()
    users,err = db.Prepared("SELECT * FROM users").FetchAll()

获得一个数据或者多个数据映射到对象中

    type Users struct {
    	Id         int64
    	Mobile     string
    	Nickname   string
    	CreateTime time.Time `db:"create_time"`
    	UpdateTime time.Time `db:"update_time"`
    }

    var user Users
    var users []Users

    db := conns.Slave()
    user, err := db.Prepared("SELECT * FROM users").ScanOne(&user)
    users,err := db.Prepared("SELECT * FROM users").ScanAll(&users)

增删改

    db := conns.Master()
    insertId,err := db.Prepared("INSERT INTO `usertest` values (null,?,?,?,?)", "18600000000", "RbTest", time.Now(), time.Now()).LastInsertID()
    affectedCount, err := db.Prepared("DELETE FROM `usertest` WHERE `id`=?", 1).AffectedCount()

事务

只有写库才能开启事务

    db := conns.Master()
    if err := db.Begin(); err != nil {
    		//
    }
    
    insertId,err := db.Prepared("INSERT INTO `usertest` values (null,?,?,?,?)", "18600000000", "RbTest", time.Now(), time.Now()).LastInsertID()
    if err!=nil || insertId==0{
    	db.Rollback()
    }
    
    //其他逻辑
    
    db.Commit()
    
    

注意

db := conns.Master()

获得db链接，该链接对象并非协程安全，但连接池是协程安全的，所以如果有协程场景，务必在每一个协程中独立获取DB链接对象。