xorm/docs/QuickStart.md

505 lines
18 KiB
Markdown
Raw Normal View History

2013-09-11 08:23:10 +00:00
xorm 快速入门
=====
2013-09-11 09:00:36 +00:00
* [1.创建Orm引擎](#10)
* [2.定义表结构体](#20)
* [2.1.名称映射规则](#21)
* [2.2.使用Table和Tag改变名称映射](#22)
* [2.3.Column属性定义](#23)
* [3.创建表](#30)
* [3.1.同步数据库结构](#31)
2013-09-11 09:00:36 +00:00
* [4.删除表](#40)
* [5.插入数据](#50)
* [6.查询和统计数据](#60)
* [6.1.查询条件方法](#61)
* [6.2.Get方法](#62)
* [6.3.Find方法](#63)
2013-10-17 05:15:29 +00:00
* [6.4.Iterate方法](#64)
* [6.5.Count方法](#65)
* [6.6.匿名结构体成员](#66)
2013-09-11 09:00:36 +00:00
* [7.更新数据](#70)
* [8.删除数据](#80)
* [9.执行SQL查询](#90)
* [10.执行SQL命令](#100)
* [11.事务处理](#110)
* [12.缓存](#120)
* [13.Examples](#130)
* [14.案例](#140)
* [15.FAQ](#150)
2013-10-17 05:15:29 +00:00
* [16.讨论](#160)
2013-09-11 08:23:10 +00:00
<a name="10" id="10"></a>
2013-09-11 09:00:36 +00:00
## 1.创建Orm引擎
2013-09-11 08:23:10 +00:00
在xorm里面可以同时存在多个Orm引擎一个Orm引擎称为Engine。因此在使用前必须调用NewEngine
```Go
2013-09-11 09:00:36 +00:00
import (
2013-10-21 14:23:45 +00:00
_ "github.com/go-sql-driver/mysql"
2013-09-11 09:00:36 +00:00
"github.com/lunny/xorm"
)
engine, err := xorm.NewEngine("mysql", "root:123@/test?charset=utf8")
defer engine.Close()
```
or
```Go
import (
_ "github.com/mattn/go-sqlite3"
"github.com/lunny/xorm"
)
engine, err = xorm.NewEngine("sqlite3", "./test.db")
defer engine.Close()
2013-09-11 08:23:10 +00:00
```
一般如果只针对一个数据库进行操作只需要创建一个Engine即可。Engine支持在多GoRutine下使用。
xorm当前支持四种驱动如下
* Mysql: [github.com/Go-SQL-Driver/MySQL](https://github.com/Go-SQL-Driver/MySQL)
* MyMysql: [github.com/ziutek/mymysql/godrv](https://github.com/ziutek/mymysql/godrv)
* SQLite: [github.com/mattn/go-sqlite3](https://github.com/mattn/go-sqlite3)
2013-09-11 09:28:27 +00:00
* Postgres: [github.com/bylevel/pq](https://github.com/bylevel/pq)
2013-09-11 08:23:10 +00:00
NewEngine传入的参数和`sql.Open`传入的参数完全相同,因此,使用哪个驱动前,请查看此驱动中关于传入参数的说明文档。
在engine创建完成后可以进行一些设置
2013-09-11 09:00:36 +00:00
2013-09-11 08:23:10 +00:00
1.设置`engine.ShowSQL = true`则会在控制台打印出生成的SQL语句如果希望用其它方式记录则可以`engine.Logger`赋值为一个`io.Writer`的实现。比如记录到Log文件则可以
```Go
f, err := os.Create("sql.log")
if err != nil {
println(err.Error())
return
}
engine.Logger = f
```
2.engine内部支持连接池接口默认使用的Go所实现的连接池同时自带了另外两种实现一种是不使用连接池另一种为一个自实现的连接池。推荐使用Go所实现的连接池。如果要使用自己实现的连接池可以实现`xorm.IConnectPool`并通过`engine.SetPool`进行设置。
如果需要设置连接池的空闲数大小,可以使用`engine.Pool.SetIdleConns()`来实现。
3.设置`engine.ShowDebug = true`,则会在控制台打印调试信息。
2013-09-11 08:23:10 +00:00
<a name="20" id="20"></a>
2013-09-11 09:00:36 +00:00
## 2.定义表结构体
2013-09-11 08:23:10 +00:00
xorm支持将一个struct映射为数据库中对应的一张表。映射规则如下
2013-09-11 09:00:36 +00:00
<a name="21" id="21"></a>
### 2.1.名称映射规则
2013-09-11 08:23:10 +00:00
名称映射规则主要负责结构体名称到表名和结构体field到表字段的名称映射。由xorm.IMapper接口的实现者来管理xorm内置了两种IMapper实现`SnakeMapper` 和 `SameMapper`。SnakeMapper支持struct为驼峰式命名表结构为下划线命名之间的转换SameMapper支持相同的命名。当前SnakeMapper为默认值当需要改变时在engine创建完成后使用
```Go
engine.Mapper = SameMapper{}
```
当然如果你使用了别的命名规则映射方案也可以自己实现一个IMapper。
2013-09-11 09:00:36 +00:00
<a name="22" id="22"></a>
### 2.2.使用Table和Tag改变名称映射
2013-09-11 08:23:10 +00:00
如果所有的命名都是按照IMapper的映射来操作的那当然是最理想的。但是如果碰到某个表名或者某个字段名跟映射规则不匹配时我们就需要别的机制来改变。
通过`engine.Table()`方法可以改变struct对应的数据库表的名称通过sturct中field对应的Tag中使用`xorm:"'table_name'"`可以使该field对应的Column名称为指定名称。这里使用两个单引号将Column名称括起来是为了防止名称冲突因为我们在Tag中还可以对这个Column进行更多的定义。如果名称不冲突的情况单引号也可以不使用。
2013-09-11 09:00:36 +00:00
<a name="23" id="23"></a>
### 2.3.Column属性定义
2013-09-11 08:23:10 +00:00
我们在field对应的Tag中对Column的一些属性进行定义定义的方法基本和我们写SQL定义表结构类似比如
```
type User struct {
Id int64
Name string `xorm:"varchar(25) not null unique 'usr_name'"`
}
```
对于不同的数据库系统数据类型其实是有些差异的。因此xorm中对数据类型有自己的定义基本的原则是尽量兼容各种数据库的字段类型具体的字段对应关系可以查看[字段类型对应表](https://github.com/lunny/xorm/blob/master/docs/COLUMNTYPE.md)。
2013-09-11 08:23:10 +00:00
具体的映射规则如下另Tag中的关键字均不区分大小写字段名区分大小写
<table>
<tr>
<td>name</td><td>当前field对应的字段的名称可选如不写则自动根据field名字和转换规则命名</td>
</tr>
<tr>
<td>pk</td><td>是否是Primary Key当前仅支持int64类型</td>
</tr>
<tr>
<td>当前支持30多种字段类型详情参见 [字段类型](https://github.com/lunny/xorm/blob/master/docs/COLUMNTYPE.md)</td><td>字段类型</td>
2013-09-11 08:23:10 +00:00
</tr>
<tr>
<td>autoincr</td><td>是否是自增</td>
</tr>
<tr>
<td>[not ]null</td><td>是否可以为空</td>
</tr>
<tr>
<td>unique或unique(uniquename)</td><td>是否是唯一如不加括号则该字段不允许重复如加上括号则括号中为联合唯一索引的名字此时如果有另外一个或多个字段和本unique的uniquename相同则这些uniquename相同的字段组成联合唯一索引</td>
</tr>
<tr>
<td>index或index(indexname)</td><td>是否是索引如不加括号则该字段自身为索引如加上括号则括号中为联合索引的名字此时如果有另外一个或多个字段和本index的indexname相同则这些indexname相同的字段组成联合索引</td>
</tr>
<tr>
<td>extends</td><td>应用于一个匿名结构体之上,表示此匿名结构体的成员也映射到数据库中</td>
</tr>
<tr>
<td>-</td><td>这个Field将不进行字段映射</td>
</tr>
<tr>
<td>-></td><td>这个Field将只写入到数据库而不从数据库读取</td>
</tr>
<tr>
2013-09-11 09:03:01 +00:00
<td>&lt;-</td><td>这个Field将只从数据库读取而不写入到数据库</td>
2013-09-11 08:23:10 +00:00
</tr>
<tr>
<td>created</td><td>这个Field将在Insert时自动赋值为当前时间</td>
</tr>
<tr>
<td>updated</td><td>这个Field将在Insert或Update时自动赋值为当前时间</td>
</tr>
<tr>
2013-09-11 09:11:40 +00:00
<td>default 0</td><td>设置默认值紧跟的内容如果是Varchar等需要加上单引号</td>
2013-09-11 08:23:10 +00:00
</tr>
</table>
另外有如下几条自动映射的规则:
2013-09-11 09:00:36 +00:00
- 1.如果field名称为`Id`而且类型为`int64`的话会被xorm视为主键并且拥有自增属性。如果想用`Id`以外的名字做为主键名可以在对应的Tag上加上`xorm:"pk"`来定义主键。
2013-09-11 08:23:10 +00:00
2013-09-11 09:00:36 +00:00
- 2.string类型默认映射为varchar(255)如果需要不同的定义可以在tag中自定义
2013-09-11 08:23:10 +00:00
2013-09-11 09:00:36 +00:00
- 3.支持`type MyString string`等自定义的field支持Slice, Map等field成员这些成员默认存储为Text类型并且默认将使用Json格式来序列化和反序列化。也支持数据库字段类型为Blob类型如果是Blob类型则先使用Jsong格式序列化再转成[]byte格式。当然[]byte或者[]uint8默认为Blob类型并且都已二进制方式存储。
2013-09-11 08:23:10 +00:00
2013-09-24 17:31:25 +00:00
- 4.实现了Conversion接口的类型或者结构体将根据接口的转换方式在类型和数据库记录之间进行相互转换。
```Go
type Conversion interface {
FromDB([]byte) error
ToDB() ([]byte, error)
}
```
2013-09-11 08:23:10 +00:00
<a name="30" id="30"></a>
2013-09-11 09:00:36 +00:00
## 3.创建表
2013-09-11 08:23:10 +00:00
创建表使用`engine.CreateTables()`参数为一个或多个空的对应Struct的指针。同时可用的方法有Charset()和StoreEngine()如果对应的数据库支持这两个方法可以在创建表时指定表的字符编码和使用的引擎。当前仅支持Mysql数据库。
在创建表时会判断表是否已经创建如果已经创建则不再创建。在创建表的过程中如果在tag中定义了索引则索引也会自动创建。
<a name="30" id="30"></a>
## 3.1.同步数据库结构
同步表能够部分智能的根据结构体的变动检测表结构的变动,并自动同步。目前能够实现:
1) 自动检测和创建表
2自动检测和新增表中的字段
3自动检测和创建索引和唯一索引
调用方法如下:
```Go
err := engine.Sync(new(User))
```
2013-09-11 08:23:10 +00:00
<a name="40" id="40"></a>
2013-09-11 09:00:36 +00:00
## 4.删除表
删除表使用`engine.DropTables()`参数为一个或多个空的对应Struct的指针或者表的名字。如果为string传入则只删除对应的表如果传入的为Struct则删除表的同时还会删除对应的索引。
2013-09-11 08:23:10 +00:00
<a name="50" id="50"></a>
2013-09-11 09:00:36 +00:00
## 5.插入数据
2013-09-11 08:23:10 +00:00
插入数据使用Insert方法Insert方法的参数可以是一个或多个Struct的指针一个或多个Struct的Slice的指针。
如果传入的是Slice并且当数据库支持批量插入时Insert会使用批量插入的方式进行插入。
```Go
user := new(User)
user.Name = "myname"
affcted, err := engine.Insert(user)
```
在插入成功后如果该结构体有PK字段则PK字段会被自动赋值为数据库中的id
```Go
fmt.Println(user.Id)
```
<a name="60" id="60"></a>
2013-09-11 09:00:36 +00:00
## 6.查询和统计数据
所有的查询条件不区分调用顺序但必须在调用GetFindCount这三个函数之前调用。同时需要注意的一点是在调用的参数中所有的字符字段名均为映射后的数据库的字段名而不是field的名字。
<a name="61" id="61"></a>
### 6.1.查询条件方法
2013-09-11 08:23:10 +00:00
查询和统计主要使用`Get`, `Find`, `Count`三个方法。在进行查询时可以使用多个方法来形成查询条件,条件函数如下:
* Id(int64)
传入一个PK字段的值作为查询条件
* Where(string, …interface{})
和Where语句中的条件基本相同作为条件
* Cols(…string)
只查询或更新某些指定的字段默认是查询所有映射的字段或者根据Update的第一个参数来判断更新的字段。例如
```Go
engine.Cols("age, name").Update(&user)
```
2013-09-11 08:23:10 +00:00
or
```Go
engine.Cols("age", "name").Update(&user)
```
2013-09-11 08:23:10 +00:00
* Sql(string, …interface{})
执行指定的Sql语句并把结果映射到结构体
* Table()
指定特殊的Table名如不加此函数则根据系统的IMapper自动映射的表名进行查询
* Asc(…string)
指定字段名正序排序
* Desc(…string)
指定字段名逆序排序
* OrderBy()
按照指定的顺序进行排序
* NoAutoTime()
如果此方法执行则此次生成的语句中Created和Updated字段将不自动赋值为当前时间
2013-09-11 08:23:10 +00:00
* In(string, …interface{})
某字段在一些值中
* Table(nameOrStructPtr interface{})
传入表名称或者结构体指针如果传入的是结构体指针则按照IMapper的规则提取出表名
* Limit(int, …int)
限制获取的数目,第一个参数为条数,第二个参数为可选,表示开始位置
* Join(string,string,string)
第一个参数为连接类型当前支持INNER, LEFT OUTER, CROSS中的一个值第二个参数为表名第三个参数为连接条件
* GroupBy(string)
Groupby的参数字符串
* Having(string)
Having的参数字符串
* Cascade(bool)
是否自动关联查询field中的数据如果struct的field也是一个struct并且映射为某个Id则可以在查询时自动调用Get方法查询出对应的数据。
2013-09-11 09:00:36 +00:00
<a name="62" id="62"></a>
### 6.2.Get方法
2013-09-11 08:23:10 +00:00
2013-09-11 09:00:36 +00:00
查询单条数据使用`Get`方法在调用Get方法时需要传入一个对应结构体的指针同时结构体中的非空field自动成为查询的条件和前面的方法条件组合在一起查询。
2013-09-11 08:23:10 +00:00
如:
1) 根据Id来获得单条数据:
2013-09-11 08:23:10 +00:00
```Go
user := new(User)
has, err := engine.Id(id).Get(user)
```
2) 根据Where来获得单条数据
```Go
user := new(User)
has, err := engine.Where("name=?", "xlw").Get(user)
```
3) 根据user结构体中已有的非空数据来获得单条数据
```Go
user := &User{Id:1}
has, err := engine.Get(user)
```
或者其它条件
2013-09-11 08:23:10 +00:00
```Go
user := &User{Name:"xlw"}
has, err := engine.Get(user)
```
返回的结果为两个参数,一个`has`为该条记录是否存在,第二个参数`err`为是否有错误。不管err是否为nilhas都有可能为true或者false。
2013-09-11 08:23:10 +00:00
2013-09-11 09:00:36 +00:00
<a name="63" id="63"></a>
### 6.3.Find方法
查询多条数据使用`Find`方法Find方法的第一个参数为`slice`的指针或`Map`指针即为查询后返回的结果第二个参数可选为查询的条件struct的指针。
2013-09-11 08:23:10 +00:00
1) 传入Slice用于返回数据
2013-09-11 08:23:10 +00:00
```Go
2013-09-11 09:00:36 +00:00
var everyone []Userinfo
err := engine.Find(&everyone)
```
2) 传入Map用户返回数据map必须为`map[int64]Userinfo`的形式map的key为id
```Go
2013-09-11 09:00:36 +00:00
users := make(map[int64]Userinfo)
err := engine.Find(&users)
2013-09-11 08:23:10 +00:00
```
3) 也可以加入条件
```Go
users := make([]Userinfo, 0)
err := engine.Where("age > ? or name=?)", 30, "xlw").Limit(20, 10).Find(&users)
```
2013-09-11 09:00:36 +00:00
<a name="64" id="64"></a>
2013-10-17 05:15:29 +00:00
### 6.4.Iterate方法
Iterate方法提供逐条执行查询到的记录的方法他所能使用的条件和Find方法完全相同
```Go
err := engine.Where("age > ? or name=?)", 30, "xlw").Iterate(new(Userinfo), func(i int, bean interface{})error{
user := bean.(*Userinfo)
//do somthing use i and user
})
```
<a name="65" id="65"></a>
### 6.5.Count方法
2013-09-11 09:00:36 +00:00
统计数据使用`Count`方法Count方法的参数为struct的指针并且成为查询条件。
2013-09-11 08:23:10 +00:00
```Go
user := new(User)
total, err := engine.Where("id >?", 1).Count(user)
```
2013-10-17 05:15:29 +00:00
<a name="66" id="66"></a>
2013-09-11 09:00:36 +00:00
### 6.5.匿名结构体成员
如果在struct中拥有一个struct并且在Tag中标记为extends那么该结构体的成员将作为本结构体的成员进行映射。
请查看Examples中的derive.go文件。
2013-09-11 08:23:10 +00:00
<a name="70" id="70"></a>
2013-09-11 09:00:36 +00:00
## 7.更新数据
更新数据使用`Update`方法Update方法的第一个参数为需要更新的内容可以为一个结构体指针或者一个Map[string]interface{}类型。当传入的为结构体指针时只有非空和0的field才会被作为更新的字段。当传入的为Map类型时key为数据库Column的名字value为要更新的内容。
2013-09-11 08:23:10 +00:00
```Go
user := new(User)
user.Name = "myname"
affected, err := engine.Id(id).Update(&user)
```
<a name="80" id="80"></a>
2013-09-11 09:00:36 +00:00
## 8.删除数据
删除数据`Delete`方法参数为struct的指针并且成为查询条件。
2013-09-11 08:23:10 +00:00
```Go
user := new(User)
affected, err := engine.Id(id).Delete(user)
2013-09-11 08:23:10 +00:00
```
`Delete`的返回值第一个参数为删除的记录数,第二个参数为错误。
2013-09-11 08:23:10 +00:00
<a name="90" id="90"></a>
2013-09-11 09:00:36 +00:00
## 9.执行SQL查询
也可以直接执行一个SQL查询即Select命令。在Postgres中支持原始SQL语句中使用 ` 和 ? 符号。
2013-09-11 08:23:10 +00:00
```Go
2013-09-11 09:00:36 +00:00
sql := "select * from userinfo"
results, err := engine.Query(sql)
2013-09-11 08:23:10 +00:00
```
<a name="100" id="100"></a>
2013-09-11 09:00:36 +00:00
## 10.执行SQL命令
也可以直接执行一个SQL命令即执行Insert Update Delete 等操作。同样在Postgres中支持原始SQL语句中使用 ` 和 ? 符号。
2013-09-11 08:23:10 +00:00
```Go
2013-09-11 09:00:36 +00:00
sql = "update userinfo set username=? where id=?"
res, err := engine.Exec(sql, "xiaolun", 1)
2013-09-11 08:23:10 +00:00
```
<a name="110" id="110"></a>
2013-09-11 09:00:36 +00:00
## 11.事务处理
2013-09-11 08:23:10 +00:00
当使用事务处理时需要创建Session对象。
```Go
// add Begin() before any action
err := session.Begin()
user1 := Userinfo{Username: "xiaoxiao", Departname: "dev", Alias: "lunny", Created: time.Now()}
_, err = session.Insert(&user1)
if err != nil {
session.Rollback()
return
}
user2 := Userinfo{Username: "yyy"}
_, err = session.Where("id = ?", 2).Update(&user2)
if err != nil {
session.Rollback()
return
}
_, err = session.Exec("delete from userinfo where username = ?", user2.Username)
if err != nil {
session.Rollback()
return
}
// add Commit() after all actions
err = session.Commit()
if err != nil {
return
}
```
2013-09-11 09:00:36 +00:00
<a name="120" id="120"></a>
## 12.缓存
xorm内置了一致性缓存支持不过默认并没有开启。要开启缓存需要在engine创建完后进行配置
启用一个全局的内存缓存
```Go
cacher := xorm.NewLRUCacher(xorm.NewMemoryStore(), 1000)
engine.SetDefaultCacher(cacher)
```
2013-09-29 14:00:21 +00:00
上述代码采用了LRU算法的一个缓存缓存方式是存放到内存中缓存struct的记录数为1000条缓存针对的范围是所有具有主键的表没有主键的表中的数据将不会被缓存。
如果只想针对部分表,则:
```Go
cacher := xorm.NewLRUCacher(xorm.NewMemoryStore(), 1000)
engine.MapCacher(&user, cacher)
```
如果要禁用某个表的缓存,则:
```Go
engine.MapCacher(&user, nil)
```
设置完之后,其它代码基本上就不需要改动了,缓存系统已经在后台运行。
当前实现了内存存储的CacheStore接口MemoryStore如果需要采用其它设备存储可以实现CacheStore接口。
不过需要特别注意不适用缓存或者需要手动编码的地方:
1. 在Get或者Find时使用了Cols方法在开启缓存后此方法无效系统仍旧会取出这个表中的所有字段。
2. 在使用Exec方法执行了方法之后可能会导致缓存与数据库不一致的地方。因此如果启用缓存尽量避免使用Exec。如果必须使用则需要在使用了Exec之后调用ClearCache手动做缓存清除的工作。比如
```Go
engine.Exec("update user set name = ? where id = ?", "xlw", 1)
engine.ClearCache(new(User))
```
缓存的实现原理如下图所示:
2013-09-29 08:48:33 +00:00
![cache design](https://raw.github.com/lunny/xorm/master/docs/cache_design.png)
2013-10-17 05:15:29 +00:00
<a name="130" id="130"></a>
## 13.Examples
2013-09-11 09:00:36 +00:00
请访问[https://github.com/lunny/xorm/tree/master/examples](https://github.com/lunny/xorm/tree/master/examples)
2013-10-17 05:15:29 +00:00
<a name="140" id="140"></a>
## 14.案例
2013-09-11 09:00:36 +00:00
* [GoDaily Go语言学习网站](http://godaily.org),源代码 [github.com/govc/godaily](http://github.com/govc/godaily)
2013-10-17 05:15:29 +00:00
* [Sudochina](http://sudochina.com) 和对应的源代码[github.com/insionng/toropress](http://github.com/insionng/toropress)
2013-09-11 09:00:36 +00:00
2013-10-17 05:28:42 +00:00
* [VeryHour](http://veryhour.com)
2013-10-17 05:15:29 +00:00
<a name="150" id="150"></a>
## 15.讨论
2013-09-11 09:00:36 +00:00
请加入QQ群280360085 进行讨论。