先贴一下代码,其中,

• wrong()方法是使用gorose的事务来进行操作的.
• right()使用的底层提供事务，并且分别预设事务级别isolation=0,1,2三种不同事务级别进行同样的操作。
• 整个操作的流程是:在同一个事务里，分别插入和查询插入的数据，在未提交时，wrong()里的count未能响应到insert的变化，而right()是可以的。

package main

import (
	"context"
	"database/sql"
	"fmt"

	_ "github.com/go-sql-driver/mysql"
	"github.com/gohouse/gorose/v2"
)

var err error
var engin *gorose.Engin

/*
    CREATE DATABASE test;
    CREATE TABLE t_user(
		id INT NOT NULL,
		name VARCHAR(20) NOT NULL
	)ENGINE=InnoDB DEFAULT CHARSET=utf8;
*/

func init() {
	engin, err = gorose.Open(&gorose.Config{Driver: "mysql", Dsn: "ft:[email protected](localhost:3306)/test?charset=utf8&parseTime=true&allowNativePasswords=true"})
	if err != nil {
		panic(err)
	}
}
func DB() gorose.IOrm {
	return engin.NewOrm()
}
func main() {
	wrong()
}

func right() {
	var id = 6
	var name = "gorose"
	db := DB()
	tx, e := db.GetISession().GetIEngin().GetExecuteDB().BeginTx(context.Background(), &sql.TxOptions{
		ReadOnly: false,

		// 分别测试0，1，2，三种隔离级别，其他隔离级别该驱动不支持
		Isolation: 0,
	})
	if e != nil {
		panic(e)
	}

	_, err := tx.Exec("insert into t_user(id, name) values(?, ?)", id, name)
	if err != nil {
		tx.Rollback()
		panic(err)
	}

	res, err := tx.Query("select count(*) from t_user where id=?", id)
	if err != nil {
		tx.Rollback()
		panic(err)
	}
	var count int

	for res.Next() {
		if e := res.Scan(&count); e != nil {
			panic(e)
		}
	}
        // 不管isoloation为0还是1还是2，count都可以显示为1
	fmt.Println(count)

	if e := tx.Commit(); e != nil {
		panic(e)
	}
}

func wrong() {
	var id = 6
	var name = "gorose"

	db := DB()

	db.Begin()

	if _, e := db.Execute("insert into t_user(id, name) values(?, ?)", id, name); e != nil {
		db.Rollback()
		panic(e)
		return
	}

	rs, e := db.Query("select count(*) from t_user where id=?", id)
	if e != nil {
		db.Rollback()
		panic(e)
		return
	}

	// 期望输出count为1，实际输出为0
	// [map[count(*):0]]
	fmt.Println(rs)

	db.Commit()
}

贴一下结果:

right() isolation=0:

1

right() isolation=1:

1

right() isolation=2:

1

wrong():

[map[count(*):0]]

• right()方法，分别对isolation=1,2,0进行操作，所得到的的count都是健康的1，也就是同事务里，count可以响应到插入，哪怕是未commit。

• wrong()方法，count无法响应到insert的方法。

基于以上结论，猜测：

• gorose的事务脏了，期望同事务下的select count 和 insert可能各自进了不同的事务里，导致了事务隔离造成的count异常。

• go1.12.7

• gorose/v2

• win10 x64

• mysql, docker image<36fcb346aa55> Ver 8.0.18 for Linux on x86_64

gin框架测试orm各项功能，增删改查无问题，测试到事务的时候就报错了，只要调用rollback或commit就panic了，环境：Mac 、go 1.13.6、 gin 1.5.0、gorose 2.1.4

以下是代码： Router.GET("/commit", func(c *gin.Context) { db := models.DB() tableName := "admin" // 开始事务 db.Begin() data := map[string]interface{}{ "mobile": "11111111111", "password": utils.Md5("aaa"), "name": "ggyy", }

	res, err := db.Table(tableName).Where("id", 6).Data(data).Update()
	if res == 0 || err != nil {
		// 回滚事务
		db.Rollback()
	}
	res2, err2 := db.Table(tableName).Data(data).Insert()
	if res2 == 0 || err2 != nil {
		// 回滚事务
		db.Rollback()
	}
	// 提交事务
	db.Commit()
	c.String(200, "ok")
})

runtime error: invalid memory address or nil pointer dereference /usr/local/Cellar/go/1.13.6/libexec/src/runtime/panic.go:199 (0x4044e7b) panicmem: panic(memoryError) /usr/local/Cellar/go/1.13.6/libexec/src/runtime/signal_unix.go:394 (0x4044cb8) sigpanic: panicmem() /usr/local/Cellar/go/1.13.6/libexec/src/database/sql/sql.go:2107 (0x4584ffc) (*Tx).rollback: if !atomic.CompareAndSwapInt32(&tx.done, 0, 1) { /usr/local/Cellar/go/1.13.6/libexec/src/database/sql/sql.go:2126 (0x4684133) (*Tx).Rollback: return tx.rollback(false) /Users/cookies/go/pkg/mod/github.com/gohouse/gorose/[email protected]/session.go:106 (0x468411d) (*Session).Rollback: err = s.tx.Rollback() /Users/cookies/WWW/gin-admin/route/router.go:245 (0x46ee0ad) SetupRouter.func11: db.Rollback() /Users/cookies/go/src/github.com/gin-gonic/gin/context.go:147 (0x45563ca) (*Context).Next: c.handlersc.index /Users/cookies/go/pkg/mod/github.com/gin-contrib/[email protected]/sessions.go:52 (0x46a43c6) Sessions.func1: c.Next() /Users/cookies/go/src/github.com/gin-gonic/gin/context.go:147 (0x45563ca) (*Context).Next: c.handlersc.index /Users/cookies/go/src/github.com/gin-gonic/gin/recovery.go:83 (0x456a0b3) RecoveryWithWriter.func1: c.Next() /Users/cookies/go/src/github.com/gin-gonic/gin/context.go:147 (0x45563ca) (*Context).Next: c.handlersc.index /Users/cookies/go/src/github.com/gin-gonic/gin/logger.go:241 (0x45691e0) LoggerWithConfig.func1: c.Next() /Users/cookies/go/src/github.com/gin-gonic/gin/context.go:147 (0x45563ca) (*Context).Next: c.handlersc.index /Users/cookies/go/src/github.com/gin-gonic/gin/gin.go:412 (0x456056c) (*Engine).handleHTTPRequest: c.Next() /Users/cookies/go/src/github.com/gin-gonic/gin/gin.go:370 (0x455fc6d) (*Engine).ServeHTTP: engine.handleHTTPRequest(c) /usr/local/Cellar/go/1.13.6/libexec/src/net/http/server.go:2802 (0x4373973) serverHandler.ServeHTTP: handler.ServeHTTP(rw, req) /usr/local/Cellar/go/1.13.6/libexec/src/net/http/server.go:1890 (0x436f214) (*conn).serve: serverHandler{c.server}.ServeHTTP(w, w.req) /usr/local/Cellar/go/1.13.6/libexec/src/runtime/asm_amd64.s:1357 (0x405cee0) goexit: BYTE $0x90 // NOP

[GIN] 2020/03/13 - 19:13:03 | 500 | 3.572032ms | 127.0.0.1 | GET /commit

嵌套查询好像不好用。 `

User := ConnectionMS.NewSession().Table(t.TableName())
User.Where("name", ">", 1)
User.Where(func() {
	User.OrWhere("name", "fizz").OrWhere(func() {
		User.Where("name", "fizz2").Where(func() {
			User.Where("name", "fizz53").OrWhere("website", "like", "fizzday%")
		})
	})
})

fmt.Println(User.BuildSql())

`

居然生成SELECT * FROM T_Room_Order WHERE name > 1 and ()

是不是有什么bug

Execute()执行insert以后无法取到插入的行数量，只能返回上一次插入的最后一个ID，在某些情况下不方便使用。我看了database.go，parseExecute()时要不只返回LastInsertId，要不只返回RowsAffected，并且没有保存：

func (dba *Database) parseExecute(stmt *sql.Stmt, operType string, vals []interface{}) (int64, error) {
	var res int64
	var err error
	result, errs := stmt.Exec(vals...)
	if errs != nil {
		return 0, errs
	}

	switch operType {
	case "insert":
		res, err = result.LastInsertId()
	case "update":
		res, err = result.RowsAffected()
	case "delete":
		res, err = result.RowsAffected()
	}

	return res, err
}

能否改进一下？

之前go 1.12可以正常用v1.0.5，现在go升级到1.13 执行： go get -u github.com/gohouse/[email protected] 出错： go get github.com/gohouse/[email protected]: github.com/gohouse/[email protected]: invalid version: module contains a go.mod file, so major version must be compatible: should be v0 or v1, not v2

2.0版本规划

开发计划

按照 laravel 的数据库操作 query builder 的标准开发, 同时可酌情添加 eloquent 的部分设计思想和 api

产品规划

采用模块分离的方式, 每个模块以 接口 的方式相互调用, 做到模块相互独立, 后期可以自由方便的拓展.
比如驱动, 不同驱动的sql构建

设计目标

每个模块要做到可以自由横向扩展, 以实现个性化需求.
比如返回结果: map, struct, 自定义数据类型等.

模块大致结构图

dbconfig配置参数为map[string]interface{}格式，数据库连接配置是map[string]string格式，数据库配置项不固定，很难使用struct进行定义并加载。而且使用json/simplejson等解析工具从外部读取配置文件后，数据库配置项自动变成了map[string]interface{}格式，gorose认为是不正确的配置。能否将配置文件中的数据库配置项改成数组，以方便动态加载并自动适配？如下：

``type DBConfig struct {

Default string `json:"default"`

SetMaxOpenConns int `json:"SetMaxOpenConns"`

SetMaxIdleConns int `json:"SetMaxIdleConns"`

DBList []map[string]string `json:"dblist"`    \\ 适配可变数据库连接配置，方便进行配置文件持久化

}``

是否可行？

你好, 在使用 gorose 连接 postgresql 时, where条件中的字段名会加上 反引号`, 导致无法正确执行.

fmt.Println(db.Table("users").Where(`name`, name).BuildSql("select"))

生成的sql 如下:

SELECT * FROM users WHERE `name` =  $1 ['xxxx'];

由于 name 字段上 有反引号, 导致无法执行此SQL

• 1、BuildExecute未处理类型为string或[]string的data引起Increment,Decrement生成错误的sql如下： update xxx set where xxx = ?，丢失更新字段列表，同样的table.data('click_count=click_count+1').update()一样生成错误sql;建议允许使用如下的更新或插入方法： table.data('click_count=click_count+1,visit_count=visit_count+1, tikcet=tikcet-1').update(), // 多字段计数累加或累减

• 2、查询条件中如果where传入nil或空数组，将生成错误的sql语句，在应用中不得不如下处理：

var where [][]interface{}
if search != "" {
     where = append(where, []interface{}{"name","like", search + "%%"})
}
query := db.Table('xxxx')
if len(where) > 0 {
    query = query.where(**where**)  // 此处如果where为nil或是[]将生成错误的sql
}
rows, err := query.Get()

是否可能直接如下调用更简洁：

var where [][]interface{}
if search != "" {
     where = append(where, []interface{}{"name","like", search + "%%"})
}
rows, err := db.Table('xxxx').where(where).Get()

一个简单的例子：业务逻辑需要用到多个库（或用户），这可以在ConnectionConfigs里面配置。但是每次到切换配置时，都会用Open去建立一个新的Connection来覆盖之前Connect全局变量，之前的Connection则被“丢弃”。

PS:一开始我以为gorose.Open()会返回一条新的Connection，所以我使用map将配置对应的Connection关联，这样就不用重复Open相同的配置，结果不行，发现map中的Connection都是同一个（且最后一次Open的那个）；接着尝试GetInstance()来返回一个新的DataBase指针，利用Map对应配置，最后发现所有的DataBase指针都会去找那个全局的Connet变量。故，提出问题，望得到正解！

关于关联模型#20 ，用Join实现的并不是我想要的。 thinkphp5中有个with方法，可以实现关联模型，以单独查询一个对象为例。 系统有user、user_info、user_category三个表，其数据结构分别为：

user: id,name,gender,c_id（对应user_category的id）； user_info: id,u_id（对应user的id）,id_card user_category: id,name

在tp中可以通过：UserModel->Where("Id","=",1)->with("user_info","user_category")->find();获取如下格式的数据：

｛ id:1, name:"小明"， user_info:{u_id:1,id_card:"411423333333333333"}, user_category:{id:11,name:"老师"} ｝

这样用起来特别方便，建议gorose实现with方法。 提供一个不成熟的思路：

1.先忽略with方法，执行解析的sql语句，得到table1的一个记录。 2.定义with("relation","table2_name","table1.key","table2.key"); 3.取1中记录的table1.key的value,和with方法构成第二条sql语句，并执行。 4.将执行的结果挂载到1中的记录上。 5.返回数据

对于列表的获取，为了避免多次循环查询，可以基于步骤一做些改变，具体如下。

1.先忽略with方法，执行解析的sql语句，得到table1的记录集合。 2.定义with("relation","table2_name","table1.key","table2.key"); 3.取1中记录集合的table1.key的value构成一个IN (table1.key.v1,table1.key.v2,table1.key.v3....),和with方法构成第二条sql语句，查询出table2的集合。 4.对两个集合进行合成，基于with中的table1.key和table2.key合并集合。 5.返回列表。

如果表达的不清楚，欢迎追问。

func (dba *Orm) Where(args ...interface{}) IOrm { if len(args) == 0 || t.New(args[0]).Bool() == false { return dba } t.New(args[0]).Bool() == false

当传入单一参数false的时候，期望的是否定条件，即查不到任何记录就对了 WHERE false

这个时候不应该省略 false

而当传入单一参数true的时候，倒是可以省略的 WHERE true and id = 1 等价于 WHERE id = 1

目前可以传入 Where("1 = 0") 来代替false

例如: db.Transaction(func(db gorose.IOrm) error { var obj Obj db.Table(&obj).Where("id", 1).Select() return nil }) 在这种情况下，obj对象无法被正确赋值，查询源码后发现是在orm.go/304执行了dba.ResetTable()这个方法，我认为Transaction中即使不ResetTable，也不会对参数产生感染，因此Transaction中的Reset()能否去掉ResetTable呢？