项目简介

项目名：Beerus-DB
开发语言：golang

Beerus-DB 是 Beerus 的一个数据库操作组件，支持多数据源，连接池管理，单表操作不需要写 sql ，查询结果可以映射到 struct ，废话不多说，直接上示例。

单表操作

根据条件查询单表数据

conditions := builder.Create(). Add("id > ?", 10). Add("and (user_name = ? or age > ?)", "bee", 18). Add("order by create_time desc", entity.NotWhere). Build() resultMap, err := operation.GetDBTemplate("Data source name").Select("table name", conditions)

根据条件修改单表数据

// 条件设定 conditions := builder.Create(). Add("id = ?", 1). Build() // 要修改的数据设定 data := ResultStruct{UserName: "TestNoSqlUpdate"} // 执行修改操作 result, err := operation.GetDBTemplate("Data source name").Update("table name", dbutil.StructToMapIgnore(&data, true),conditions)

根据条件删除单表数据

// 设定删除条件 conditions := builder.Create(). Add("id = ?", 2). Build() // 执行删除操作 _, err := operation.GetDBTemplate("Data source name").Delete("table name", conditions)

插入一条数据

data := ResultStruct{ UserName: "TestNoSqlInsert", UserEmail: "[email protected]", UpdateTime: "2021-12-09 13:50:00", } result, err := operation.GetDBTemplate("Data source name").Insert("table name", dbutil.StructToMapIgnore(&data, true))

自定义 sql 操作

根据数组参数查询

param := make([]interface{}, 1) param[0] = 1 // 查多条 resultMap, err := operation.GetDBTemplate("Data source name").SelectList("select * from xt_message_board where id = ?", param) // 查一条 resultMap, err := operation.GetDBTemplate("Data source name").SelectOne("select * from xt_message_board where id = ?", param)

分页查询

data := ResultStruct{ UserName: "TestNoSqlInsert", UserEmail: "[email protected]", } // 创建分页参数 param := entity.PageParam{ CurrentPage: 1, // 第几页 PageSize: 20, // 每页多少条 Params: dbutil.StructToMap(&data)， // 查询参数 } // 执行查询操作 result, err := operation.GetDBTemplate("Data source name").SelectPage("select * from xt_message_board where user_name = {user_name} and user_email = {user_email}", param)

事务管理

// 开启事务 id, err := db.Transaction() if err != nil { t.Error("TestUpdateTx: " + err.Error()) return } res := ResultStruct{Id: 1, UserName: "TestUpdateTx"} // 注：这里使用的不是 GetDBTemplate ，ExecByMap ，而是 GetDBTemplateTx 和 ExecByTxMap // 使用事务和不使用事务，在调用的函数上，区别就是多了个 Tx ss, err := operation.GetDBTemplateTx(id, "dbPoolTest").ExecByTxMap("update xt_message_board set user_name = {user_name} where id = {id}", dbutil.StructToMap(&res)) if err != nil { // 如果有问题就回滚事务 db.Rollback(id) t.Error("TestUpdateTx: " + err.Error()) return } // 提交事务 db.Commit(id)