sorm: sorm golang 基于原生驱动适配了国产化数据库的orm 框架

sorm-logo

SORM 操作框架，是一款适配国产化数据库操作的golang orm 框架，内部适配分库分表策略，提供类似于GORM的操作形式。内部包含所有数据库驱动，直接使用原生的驱动构建而成，提供一站式数据托管的数据操作能力。欢迎对数据库感兴趣的小伙伴一起来改进这个库，毕竟以我自己一个人的力量还是微小，很多不足之处，欢迎给我留言。 [TOC]

目前支持的数据库驱动如下：

后期改进

神通和达梦的数据库大小写还是很反人类，设置大小写敏感，使用小写自动转成大写了，如果想使用小写需要使用"" 括起来处理，但是sql 又比较灵活，还有很多聚合和统计的函数不能一一实现，索性就让这两个数据库都使用大写的表名和字段去处理
关于数据库的自增，目前只支持字段自增，不能使用sequence，因为要同时兼容很多数据库，需要适配，这是也是一个坑。
还有一些数据库方言类的数据格式需要适配，可能需要一些细微的调整

数据库分库分表功能：

表指定数据库

// 单独给一个表存放一个数据库：
// cofnig 是数据库的配置文件
engine.AddDB("user", &conf)

分表策略

// TableName:表名
// TableShardType 分表策略
// TableSegName 表中分表的字段
engine.AddSpliter( spliter.Split{TableName: tableName, TableShardType: shardType, TableSegName: segName})

取模

%5:按照取模来分表,user_0、user_1,user_2、user_3,user_4
按照分表字段的对应的值 取模上面的数字，例如表名，user,分表的字段是age，按照分表策略%2，生成的表名就是user_0、user_1

时间：

m:按照月来分表 对应的表名为user_202001,user_202002,user_202003...
d:按照天来分表 对应的表名为,user_20200101,user_20200102,user_20200103...      
w:按照周来分表 对应的表名为user_202028,user_202029,user_202030,...
h:按照小时来分表 对应的表为user_2020010101 
y:按照年来分表 对应的表名为user_2020,user_2021,user_2022,user_2023,...

数据库操作

初始化数据库引擎

conf := server.Config{ // 初始化一个engine
		Type:     "dm",
		Host:     "192.168.81.36",
		Port:     5236,
		Username: "test",
		Password: "123456",
		Database: "test",
	}

	engine, err := NewEngineWithConfig(&conf)
	if err != nil {
		t.Fatal("failed to connect", err)
	}

定义数据表结构

type User struct {
	Name       string    `column:"name" sorm:"PRIMARY KEY"`
	Age        int       `json:"age" form:"age" column:"age"`
	CreateTime time.Time `json:"create_time" form:"create_time"  column:"create_time"`
	Num        *int      `json:"num"  form:"num"  column:"num"`
}

func (u *User) GetTableName() string {
	return "user"
}

上述代码定义了一个名为 User 的结构体，它对应数据库中的 user 表。结构体字段使用 column 标签指定了对应的数据库列名。
目前仅支持自增主键，使用 sorm:"PRIMARY KEY" 来表示，还未启用各个数据库的sequence,这个功能还没想好怎么加。

事务

事务框架会自动代理所有的数据库，提供整体的事务处理    
使用数据库引擎的 Transaction 方法可以进行数据库事务操作。示例如下：

engine.Transaction(func(s *session.Session) (result interface{}, err error) {
	s.Where("name =?", "John").First(&User{}) // find a user with name "John"") 
	
}

创建数据：

使用数据库引擎的 Create 方法可以向数据库中插入数据。示例如下：

func create(t *testing.T) {
	engine := OpenDB(t)
	defer engine.Close()

	u1 := User{Name: "Tom", CreateTime: time.Now()}
	us := []User{
		{Name: "Tom", Age: 18, CreateTime: t1, Num: n1},
		{Name: "liu", Age: 19, CreateTime: t1, Num: n1},
		{Name: "lao", Age: 20, CreateTime: time.Now()},
		{Name: "ban", Age: 21, CreateTime: time.Now()},
	}

	s := engine.NewSession()

	_, err := s.Create(&us)
	if err != nil {
		log.Infof("err:%+v\n", err)
		return
	}

	_, err = s.Create(&u1)
	if err != nil {
		log.Infof("err:%+v\n", err)
		return
	}

	_, err = s.Select("name", "age").Create(&u1)
	if err != nil {
		log.Infof("err:%+v\n", err)
		return
	}

	_, err = s.Select("name", "age").Create(&us)
	if err != nil {
		log.Infof("err:%+v\n", err)
		return
	}
}

上述代码通过调用 engine.NewSession 创建一个数据库会话，然后使用会话的 Create 方法插入数据。可以一次插入多个数据，传入的参数为对应的结构体和切片。

查询数据

查询数据可选的方法就就比较多了

Select("name", "age")  // 选择指定的字段
Omit("name") // 选择不显示指定的字段
Join(LEFT, "a", "a.id=b.id") // join 类型/表/连接条件
Limit(10)
Offset(10)
OrderBy("name desc") // order by
GroupBy("name") // group by
Having  


var ps []Point

err := s.Model(&Point{}).Select("t19").Find(&ps)
if err != nil {
    panic(err)
}

fmt.Println("ps:", ps)

更新数据

func UpdatePoint(t *testing.T) {
	engine := OpenDB(t)
	defer engine.Close()
	//engine.AddUserSplitter()
	s := engine.NewSession()

	_, err := s.Model(&Point{}).Where("num = ?", 1).Update("t19 = ?", time.Now())
	if err != nil {
		panic(err)
	}

}

删除数据


func deletePointTran(t *testing.T) {

	engine := OpenDB(t)
	defer engine.Close()
	engine.AddUserSplitter()

	engine.Transaction(func(s *session.Session) (interface{}, error) {
		_, err := s.Model(&Point{}).Where("num = ? and name = ?", 4, "liu").Delete()

		if err != nil {
			panic(err)
		}
		return nil, nil
	})

}

yunyouzi / sorm

目前支持的数据库驱动如下：

后期改进

数据库分库分表功能：

表指定数据库

分表策略

取模

时间：

数据库操作

初始化数据库引擎

定义数据表结构

事务

创建数据：

查询数据

更新数据

删除数据

简介

发行版 (1)

贡献者

近期动态

yunyouzi / sorm .gitee-modal { width: 500px !important; }

目前支持的数据库驱动如下：

后期改进

数据库分库分表功能：

表指定数据库

分表策略

取模

时间：

数据库操作

初始化数据库引擎

定义数据表结构

事务

创建数据：

查询数据

更新数据

删除数据

简介

发行版 (1)

贡献者

近期动态

搜索帮助

yunyouzi / sorm