xorm xorm 是一个而强大的 Go 言 ORM. 通它可以使数据操作非常便 xorm 的目并不是你完全不去学 SQL, 我 SQL 并不会 ORM 所替代, 但是 ORM 将可以解决大部分的 SQL 需求 xorm 支持种格的混用特性支持 Struct 和数据表之的灵

Size: px

Start display at page:

Download "xorm xorm 是一个而强大的 Go 言 ORM. 通它可以使数据操作非常便 xorm 的目并不是你完全不去学 SQL, 我 SQL 并不会 ORM 所替代, 但是 ORM 将可以解决大部分的 SQL 需求 xorm 支持种格的混用特性支持 Struct 和数据表之的灵"

渔咎
6 years ago
Views:

1 Table of Contents 1. Introduction 2. 建 Orm 引擎 3. 定表体 i. 名称映射 ii. 前映射, 后映射和存映射 iii. 使用 Table 和 Tag 改名称映射 iv. Column 属性定 v. Go 与字段型表 4. 表操作 i. 取数据信息 ii. 表操作 iii. 建索引和唯一索引 iv. 同步数据 v. 出入 SQL 脚本 5. 插入数据 i. 建 Created 6. 和数据 i. 条件方法 ii. 开关方法 iii. Get 方法 iv. Find 方法 v. Iterate 方法 vi. Count 方法 vii. Rows 方法 7. 更新数据 i. Version ii. 更新 Updated 8. 除数据 i. 除 Deleted 9. 行 SQL 10. 行 SQL 命令 11. 事理 12. 存 13. 事件 14. xorm 工具 15. 常 16. 案例 17. 更新日志

2 xorm xorm 是一个而强大的 Go 言 ORM. 通它可以使数据操作非常便 xorm 的目并不是你完全不去学 SQL, 我 SQL 并不会 ORM 所替代, 但是 ORM 将可以解决大部分的 SQL 需求 xorm 支持种格的混用特性支持 Struct 和数据表之的灵活映射, 并支持自同步表事支持支持原始 SQL 句和 ORM 操作的混合行使用写来化用支持使用 Id, In, Where, Limit, Join, Having, Table, Sql, Cols 等函数和体等方式作条件支持加 Struct 支持 LRU 存 ( 支持 memory, memcache, leveldb, redis 存 Store) 和 Redis 存支持反, 即根据数据自生成 xorm 的体支持事件支持 created, updated, deleted 和 version 版本 ( 即 ) 支持 xorm 当前支持的和数据如下 : Mysql: github.com/go-sql-driver/mysql MyMysql: github.com/ziutek/mymysql/godrv SQLite: github.com/mattn/go-sqlite3 Postgres: github.com/lib/pq MsSql: github.com/denisenkom/go-mssqldb MsSql: github.com/lunny/godbc 安装推荐使用 gopm 行安装 : gopm get github.com/go-xorm/xorm 或者您也可以使用 go 工具行安装 : go get github.com/go-xorm/xorm

3 文档操作指南 GoWalker 代文档 Godoc 代文档加入 QQ 群 : 行献如果您也想 Xorm 献您的力量, 看 CONTRIBUTING LICENSE BSD License

4 建 Orm 引擎在 xorm 里面, 可以同存在多个 Orm 引擎, 一个 Orm 引擎称 Engine Engine 通用 xorm.newengine 生成, 如 : import ( _ "github.com/go-sql-driver/mysql" "github.com/go-xorm/xorm" ) var engine *xorm.engine func main() { var err error engine, err = xorm.newengine("mysql", "root:123@/test?charset=utf8") } or import ( _ "github.com/mattn/go-sqlite3" "github.com/go-xorm/xorm" ) var engine *xorm.engine func main() { var err error engine, err = xorm.newengine("sqlite3", "./test.db") } 一般情况下如果只操作一个数据, 只需要建一个 Engine 即可 Engine 是 GoRutine 安全的于有大量数据并且需要分区的用, 也可以根据来建多个 Engine, 比如 : var err error for i:=0;i<5;i++ { engines[i], err = xorm.newengine("sqlite3", fmt.sprintf("./test%d.db", i)) } engine 可以通 engine.close 来手关, 但是一般情况下可以不用关, 在程序退出会自关 NewEngine 入的参数和 sql.open 入的参数完全相同, 因此, 在使用某个前, 看此中关于入参数的明文档以下各个的接符的文档接 : sqlite3 mysql dsn mymysql postgres 在 engine 建完成后可以行一些置, 如 : 1., 警告以及等示置, 默如下均 false engine.showsql = true, 会在控制台打印出生成的 SQL 句 ; engine.showdebug = true, 会在控制台打印信息 ; engine.showerror = true, 会在控制台打印信息 ; engine.showwarn = true, 会在控制台打印警告信息 ;

5 2. 如果希望将信息不打印到控制台, 而是保存文件, 那么可以通似如下的代, NewSimpleLogger(w io.writer) 接收一个 io.writer 接口来将数据写入到的施中 f, err := os.create("sql.log") if err!= nil { println(err.error()) return } engine.logger = xorm.newsimplelogger(f) 3.engine 内部支持接池接口和的函数如果需要置接池的空数大小, 可以使用 engine.setmaxidleconns() 来如果需要置最大打开接数, 可以使用 engine.setmaxopenconns() 来

6 2. 定表体 xorm 支持将一个 struct 映射数据中的一表映射如下 :

7 名称映射名称映射主要体名称到表名和体 field 到表字段的名称映射由 xorm.imapper 接口的者来管理,xorm 内置了种 IMapper : SnakeMapper 和 SameMapper SnakeMapper 支持 struct 峰式命名, 表下划命名之的 ;SameMapper 支持体名称和的表名称以及体 field 名称与的表字段名称相同的命名当前 SnakeMapper 默, 如果需要改, 在 engine 建完成后使用 engine.setmapper(samemapper{}) 同需要注意的是 : 如果你使用了的命名映射方案, 也可以自己一个 IMapper 表名称和字段名称的映射默是相同的, 当然也可以置不同, 如 : engine.settablemapper(samemapper{}) engine.setcolumnmapper(snakemapper{}) When a struct auto mapping to a database's table, the below table describes how they change to each other: go type's kind value method xorm type implemented Conversion Conversion.ToDB / Conversion.FromDB Text int, int8, int16, int32, uint, uint8, uint16, uint32 int64, uint64 float32 float64 Int BigInt Float Double complex64, complex128 json.marshal / json.unmarshal Varchar(64) []uint8 Blob array, slice, map except []uint8 json.marshal / json.unmarshal Text bool 1 or 0 Bool string time.time Varchar(255) DateTime cascade struct primary key field value BigInt struct json.marshal / json.unmarshal Text Others Text

8 前映射, 后映射和存映射通 engine.newprefixmapper(snakemapper{}, "prefix") 可以建一个在 SnakeMapper 的基上在命名中添加一的前, 当然也可以把 SnakeMapper{} 成 SameMapper 或者你自定的 Mapper 通 engine.newsufffixmapper(snakemapper{}, "suffix") 可以建一个在 SnakeMapper 的基上在命名中添加一的后, 当然也可以把 SnakeMapper 成 SameMapper 或者你自定的 Mapper 通 engine.newcachemapper(snakemapper{}) 可以建一个合了其它的映射, 起到在内存中存曾映射的命名映射例如, 如果希望所有的表名都在体自命名的基上加一个前而字段名不加前, 可以在 engine 建完成后行以下句 : tbmapper := engine.newprefixmapper(snakemapper{}, "prefix") engine.settablemapper(tbmapper) 行之后, 体 type User struct 默的表名就成了 prefix_user 了, 而默是 user

9 使用 Table 和 Tag 改名称映射如果所有的命名都是按照 IMapper 的映射来操作的, 那当然是最理想的但是如果碰到某个表名或者某个字段名跟映射不匹配, 我就需要的机制来改如果体有 TableName() string 的成方法, 那么此方法的返回即是体的数据表名通 engine.table() 方法可以改 struct 的数据表的名称, 通 sturct 中 field 的 Tag 中使用 xorm:"'column_name'" 可以使 field 的 Column 名称指定名称里使用个引号将 Column 名称括起来是了防止名称冲突, 因我在 Tag 中可以个 Column 行更多的定如果名称不冲突的情况, 引号也可以不使用到此名称映射的所有方法都出了, 一共三种方式, 那么三种是有先序的表名的先序如下 : engine.table() 指定的表名先最高 TableName() string 其次 Mapper 自映射的表名先最后字段名的先序如下 : 体 tag 指定的字段名先高 Mapper 自映射的表名先低

10 Column 属性定我在 field 的 Tag 中 Column 的一些属性行定, 定的方法基本和我写 SQL 定表似, 比如 : type User struct { Id int64 Name string `xorm:"varchar(25) not null unique 'usr_name'"` } 于不同的数据系, 数据型其是有些差异的因此 xorm 中数据型有自己的定, 基本的原是尽量兼容各种数据的字段型, 具体的字段关系可以看字段型表于使用者, 一般只要使用自己熟悉的数据字段定即可具体的 Tag 如下, Tag 中的关字均不区分大小写, 但字段名根据不同的数据是区分大小写 : name pk 当前支持 30 多种字段型, 情参字段型 autoincr [not ]null 或 notnull unique 或 unique(uniquename) index 或 index(indexname) extends 当前 field 的字段的名称, 可, 如不写, 自根据 field 名字和命名, 如与其它关字冲突, 使用引号括起来是否是 Primary Key, 如果在一个 struct 中有多个字段都使用了此, 多个字段成了复合主, 主当前支持 int32,int,int64,uint32,uint,uint64,string 7 种 Go 的数据型, 复合主支持 7 种 Go 的数据型的合字段型是否是自增是否可以空是否是唯一, 如不加括号字段不允重复 ; 如加上括号, 括号中合唯一索引的名字, 此如果有外一个或多个字段和本 unique 的 uniquename 相同, 些 uniquename 相同的字段成合唯一索引是否是索引, 如不加括号字段自身索引, 如加上括号, 括号中合索引的名字, 此如果有外一个或多个字段和本 index 的 indexname 相同, 些 indexname 相同的字段成合索引用于一个匿名体之上, 表示此匿名体的成也映射到数据中 - 个 Field 将不行字段映射 -> 个 Field 将只写入到数据而不从数据取 <- 个 Field 将只从数据取, 而不写入到数据 created updated 个 Field 将在 Insert 自当前个 Field 将在 Insert 或 Update 自当前 version 个 Field 将会在 insert 默 1, 每次更新自加 1 default 0 置默, 跟的内容如果是 Varchar 等需要加上引号外有如下几条自映射的 : 1. 如果 field 名称 Id 而且型 int64 并且没有定 tag, 会被 xorm 主, 并且有自增属性如果想用 Id 以外的名字或非 int64 型做主名, 必在的 Tag 上加上 xorm:"pk" 来定主, 加上 xorm:"autoincr" 作自增里需要注意的是, 有些数据并不允非主的自增属性 2.string 型默映射 varchar(255), 如果需要不同的定, 可以在 tag 中自定 3. 支持 type MyString string 等自定的 field, 支持 Slice, Map 等 field 成, 些成默存 Text 型, 并且默将使用 Json 格式来序列化和反序列化也支持数据字段型 Blob 型, 如果是 Blob 型, 先使用 Json 格式序列化再成 []byte 格式当然 []byte 或者 []uint8 默 Blob 型并且都以二制方式存具体参 Go 与字段型表 4. 了 Conversion 接口的型或者体, 将根据接口的方式在型和数据之行相互, 个接口

11 的先是最高的 type Conversion interface { FromDB([]byte) error ToDB() ([]byte, error) } 5. 如果一个体包含一个 Conversion 的接口型, 那么在取数据, 必要先置一个此接口的 struct 或者 struct 的指此可以在此 struct 中 BeforeSet(name string, cell xorm.cell) 方法来行先 Conversion 例子参 testconversion xorm mysql sqlite3 postgres remark BIT BIT INTEGER BIT TINYINT TINYINT INTEGER SMALLINT SMALLINT SMALLINT INTEGER SMALLINT MEDIUMINT MEDIUMINT INTEGER INTEGER INT INT INTEGER INTEGER INTEGER INTEGER INTEGER INTEGER BIGINT BIGINT INTEGER BIGINT CHAR CHAR TEXT CHAR VARCHAR VARCHAR TEXT VARCHAR TINYTEXT TINYTEXT TEXT TEXT TEXT TEXT TEXT TEXT MEDIUMTEXT MEDIUMTEXT TEXT TEXT LONGTEXT LONGTEXT TEXT TEXT BINARY BINARY BLOB BYTEA VARBINARY VARBINARY BLOB BYTEA DATE DATE NUMERIC DATE DATETIME DATETIME NUMERIC TIMESTAMP TIME TIME NUMERIC TIME TIMESTAMP TIMESTAMP NUMERIC TIMESTAMP TIMESTAMPZ TEXT TEXT TIMESTAMP with zone timestamp with zone info REAL REAL REAL REAL FLOAT FLOAT REAL REAL DOUBLE DOUBLE REAL DOUBLE PRECISION DECIMAL DECIMAL NUMERIC DECIMAL NUMERIC NUMERIC NUMERIC NUMERIC TINYBLOB TINYBLOB BLOB BYTEA BLOB BLOB BLOB BYTEA MEDIUMBLOB MEDIUMBLOB BLOB BYTEA

12 LONGBLOB LONGBLOB BLOB BYTEA BYTEA BLOB BLOB BYTEA BOOL TINYINT INTEGER BOOLEAN SERIAL INT INTEGER SERIAL auto increment BIGSERIAL BIGINT INTEGER BIGSERIAL auto increment

13 Go 与字段型表如果不使用 tag 来定 field 的数据字段型, 那么系会自出一个默的字段型, 表如下 : When a struct auto mapping to a database's table, the below table describes how they change to each other: go type's kind value method xorm type implemented Conversion Conversion.ToDB / Conversion.FromDB Text int, int8, int16, int32, uint, uint8, uint16, uint32 int64, uint64 float32 float64 Int BigInt Float Double complex64, complex128 json.marshal / json.unmarshal Varchar(64) []uint8 Blob array, slice, map except []uint8 json.marshal / json.unmarshal Text bool 1 or 0 Bool string time.time Varchar(255) DateTime cascade struct primary key field value BigInt struct json.marshal / json.unmarshal Text Others Text

14 表操作 xorm 提供了一些取和修改表的方法, 通些方法可以同步数据, 出数据, 入数据如果您只是需要一个工具, 可以直接使用 go install github.com/go-xorm/cmd/xorm 来安装 xorm 命令

15 取数据信息 DBMetas() xorm 支持取表信息, 通用 engine.dbmetas() 可以取到数据中所有的表, 字段, 索引的信息 TableInfo() 根据入的体指及其的 Tag, 提取出模型的表信息里不是数据当前的表信息, 而是我通 struct 建模希望数据的表的信息

16 表操作 CreateTables() 建表使用 engine.createtables(), 参数一个或多个空的 Struct 的指同可用的方法有 Charset() 和 StoreEngine(), 如果的数据支持, 个方法可以在建表指定表的字符和使用的引擎 Charset() 和 StoreEngine() 当前支持 Mysql 数据 IsTableEmpty() 判断表是否空, 参数和 CreateTables 相同 IsTableExist() 判断表是否存在 DropTables() 除表使用 engine.droptables(), 参数一个或多个空的 Struct 的指或者表的名字如果 string 入, 只除的表, 如果入的 Struct, 除表的同会除的索引

17 建索引和唯一索引 CreateIndexes 根据 struct 中的 tag 来建索引 CreateUniques 根据 struct 中的 tag 来建唯一索引

18 同步数据同步能部分智能的根据体的表的, 并自同步目前有个 : Sync 自和建表, 个是根据表的名字自和新增表中的字段, 个是根据字段名自和建索引和唯一索引, 个是根据索引的一个或多个字段名, 而不根据索引名称用方法如下 : err := engine.sync(new(user)) Sync2 Sync 行了改, 目前推荐使用 Sync2 自和建表, 个是根据表的名字自和新增表中的字段, 个是根据字段名, 同表中多余的字段出警告信息自, 建, 和除索引和唯一索引, 个是根据索引的一个或多个字段名, 而不根据索引名称自 varchar 字段型到 text 字段型, 自警告其它型不一致的情况自警告字段的默, 是否空信息在模型和数据之不匹配的情况以上些警告信息需要将 engine.showwarn 置 true 用方法和 Sync 一 : err := engine.sync2(new(user))

19 Dump 数据和数据如果需要在程序中 Dump 数据的和数据可以用 engine.dumpall(w io.writer) 和 engine.dumpallfile(fpath string) DumpAll 方法接收一个 io.writer 接口来保存 Dump 出的数据和数据的 SQL 句, 个方法出的 SQL 句并不能通用只当前 engine 所的数据支持的 SQL Import 行数据 SQL 脚本如果你需要将保存在文件或者其它存施中的 SQL 脚本行, 那么可以用 engine.import(w io.writer) 和 engine.importfile(fpath string)

20 插入数据插入数据使用 Insert 方法,Insert 方法的参数可以是一个或多个 Struct 的指, 一个或多个 Struct 的 Slice 的指如果入的是 Slice 并且当数据支持批量插入,Insert 会使用批量插入的方式行插入插入一条数据, 此可以用 Insert 或者 InsertOne user := new(user) user.name = "myname" affected, err := engine.insert(user) // INSERT INTO user (name) values (?) 在插入条数据成功后, 如果体有自增字段, 自增字段会被自数据中的 id fmt.println(user.id) 插入同一个表的多条数据, 此如果数据支持批量插入, 那么会行批量插入, 但是每条就无法被自予 id 如果数据不支持批量插入, 那么就会一条一条插入 users := make([]user, 0) users[0].name = "name0"... affected, err := engine.insert(&users) 使用指 Slice 插入多条, 同上 users := make([]*user, 0) users[0] = new(user) users[0].name = "name0"... affected, err := engine.insert(&users) 插入多条并且不使用批量插入, 此生成多条插入句, 每条均会自予 Id users := make([]*user, 0) users[0] = new(user) users[0].name = "name0"... affected, err := engine.insert(users...) 插入不同表的一条 user := new(user) user.name = "myname" question := new(question) question.content = "whywhywhwy?" affected, err := engine.insert(user, question) 插入不同表的多条

21 users := make([]user, 0) users[0].name = "name0"... questions := make([]question, 0) questions[0].content = "whywhywhwy?" affected, err := engine.insert(&users, &questions) 插入不同表的一条或多条 user := new(user) user.name = "myname"... questions := make([]question, 0) questions[0].content = "whywhywhwy?" affected, err := engine.insert(user, &questions) 里需要注意以下几点 : 里然支持同插入, 但些插入并没有事关系因此有可能在中插入出后, 后面的插入将不会批量插入会自生成 Insert into table values (),(),() 的句, 因此各个数据 SQL 句有度限制, 因此的句有一个最大的数, 根据算在 150 条左右大于 150 条后, 生成的 sql 句将太可能致行失因此在插入大量数据, 目前需要自行分割成每 150 条插入一次

22 建 Created Created 可以您在数据插入到数据自将的字段置当前, 需要在 xorm 中使用 created, 如下所示行, 的字段必 time.time 型 type User struct { Id int64 Name string CreatedAt time.time `xorm:"created"` } 在 Insert() 或 InsertOne() 方法被用,created 的字段将会被自更新当前, 如下所示 : var user User engine.insert(&user) // INSERT user (created...) VALUES (?...)

23 和数据所有的条件不区分用序, 但必在用 Get,Find,Count, Iterate, Rows 几个函数之前用同需要注意的一点是, 在用的参数中, 如果采用默的 SnakeMapper 所有的字符字段名均映射后的数据的字段名, 而不是 field 的名字

24 条件方法和主要使用 Get, Find, Count, Rows, Iterate 几个方法在行可以使用多个方法来形成条件, 条件函数如下 : Id(interface{}) 入一个 PK 字段的, 作条件, 如 engine.id(1).get(&user) // SELECT * FROM user Where id = 1 如果是复合主, 可以 engine.id(core.pk{1, "name"}).get(&user) // SELECT * FROM user Where id =1 AND name= 'name' 入的个参数按照 struct 中 pk 字段出的序 Where(string, interface{}) 和 SQL 中 Where 句中的条件基本相同, 作条件 And(string, interface{}) 和 Where 函数中的条件基本相同, 作条件 Or(string, interface{}) 和 Where 函数中的条件基本相同, 作条件 Sql(string, interface{}) 行指定的 Sql 句, 并把果映射到体 Asc( string) 指定字段名正序排序 Desc( string) 指定字段名逆序排序 OrderBy(string) 按照指定的序行排序 In(string, interface{}) 某字段在一些中, 里需要注意必是 []interface{} 才可以展开, 由于 Go 言的限制,[]int64 等不可以直接展开, 而是通一个 slice 示例代如下 : engine.in("cloumn", 1, 2, 3).Find() engine.in("column", []int{1, 2, 3}).Find() Cols( string) 只或更新某些指定的字段, 默是所有映射的字段或者根据 Update 的第一个参数来判断更新的字段例如 : engine.cols("age", "name").find(&users) // SELECT age, name FROM user engine.cols("age", "name").update(&user) // UPDATE user SET age=? AND name=? AllCols() 或更新所有字段, 一般与 Update 配合使用, 因默 Update 只更新非 0, 非 "", 非 bool 的字段 engine.allcols().id(1).update(&user) // UPDATE user SET name =?, age =?, gender =? WHERE id = 1 MustCols( string) 某些字段必更新, 一般与 Update 配合使用 Omit(...string) 和 cols 相反, 此函数指定排除某些指定的字段注意 : 此方法和 Cols 方法不可同使用 ```Go engine.omit("age", "gender").update(&user) // UPDATE user SET name =? AND department =?

25 engine.omit("age, gender").insert(&user) // INSERT INTO user (name) values (?) // 的 age 和 gender 会默 engine.omit("age", "gender").find(&users) // SELECT name FROM user // 只 select 除 age 和 gender 字段的其它字段 * Distinct( string) 按照参数中指定的字段果 ```Go engine.distinct("age", "department").find(&users) // SELECT DISTINCT age, department FROM user 注意 : 当开了存, 此方法的用将在当前中禁用存因存系当前依 Id, 而此无法得 Id Table(nameOrStructPtr interface{}) 入表名称或者体指, 如果入的是体指, 按照 IMapper 的提取出表名 Limit(int, int) 限制取的数目, 第一个参数条数, 第二个参数表示开始位置, 如果不 0 Top(int) 相当于 Limit(int, 0) Join(string,string,string) 第一个参数接型, 当前支持 INNER, LEFT OUTER, CROSS 中的一个, 第二个参数表名, 第三个参数接条件 type UserGroup struct { User `xorm:"extends"` Group `xorm:"extends"` } usergroup := make([]usergroup, 0) engine.table(&user{}).join("inner", "group", "group.id = user.group_id").find(&usergroup) GroupBy(string) Groupby 的参数字符串 Having(string) Having 的参数字符串

26 开关方法 NoAutoTime() 如果此方法行, 此次生成的句中 Created 和 Updated 字段将不自当前 NoCache() 如果此方法行, 此次生成的句在非存模式下行 UseBool(...string) 当从一个 struct 来生成条件或更新字段,xorm 会判断 struct 的 field 是否 0,"",nil, 如果以上不当做条件或者更新内容因 bool 型只有 true 和 false 种, 因此默所有 bool 型不会作条件或者更新字段如果可以使用此方法, 如果默不参数, 所有的 bool 字段都将会被使用, 如果参数不空, 参数中指定的字段名, 些字段的 bool 将被使用 NoCascade() 是否自关 field 中的数据, 如果 struct 的 field 也是一个 struct 并且映射某个 Id, 可以在自用 Get 方法出的数据

27 Get 方法条数据使用 Get 方法, 在用 Get 方法需要入一个体的指, 同体中的非空 field 自成的条件和前面的方法条件合在一起如 : 1) 根据 Id 来得条数据 : user := new(user) has, err := engine.id(id).get(user) // 复合主的取方法 // has, errr := engine.id(xorm.pk{1,2}).get(user) 2) 根据 Where 来得条数据 : user := new(user) has, err := engine.where("name=?", "xlw").get(user) 3) 根据 user 体中已有的非空数据来得条数据 : user := &User{Id:1} has, err := engine.get(user) 或者其它条件 user := &User{Name:"xlw"} has, err := engine.get(user) 返回的果个参数, 一个 has 条是否存在, 第二个参数 err 是否有不管 err 是否 nil,has 都有可能 true 或者 false

28 Find 方法多条数据使用 Find 方法,Find 方法的第一个参数 slice 的指或 Map 指, 即后返回的果, 第二个参数可, 的条件 struct 的指 1) 入 Slice 用于返回数据 everyone := make([]userinfo, 0) err := engine.find(&everyone) peveryone := make([]*userinfo, 0) err := engine.find(&peveryone) 2) 入 Map 用返回数据,map 必 map[int64]userinfo 的形式,map 的 key id, 因此于复合主无法使用种方式 users := make(map[int64]userinfo) err := engine.find(&users) pusers := make(map[int64]*userinfo) err := engine.find(&pusers) 3) 也可以加入各种条件 users := make([]userinfo, 0) err := engine.where("age >? or name =?", 30, "xlw").limit(20, 10).Find(&users)

29 Iterate 方法 Iterate 方法提供逐条行到的的方法, 他所能使用的条件和 Find 方法完全相同 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 })

30 Count 方法数据使用 Count 方法,Count 方法的参数 struct 的指并且成条件 user := new(user) total, err := engine.where("id >?", 1).Count(user)

31 Rows 方法 Rows 方法和 Iterate 方法似, 提供逐条行到的的方法, 不 Rows 更加灵活好用 user := new(user) rows, err := engine.where("id >?", 1).Rows(user) if err!= nil { } defer rows.close() for rows.next() { err = rows.scan(user) //... }

32 更新数据更新数据使用 Update 方法,Update 方法的第一个参数需要更新的内容, 可以一个体指或者一个 Map[string]interface{} 型当入的体指, 只有非空和 0 的 field 才会被作更新的字段当入的 Map 型,key 数据 Column 的名字,value 要更新的内容 user := new(user) user.name = "myname" affected, err := engine.id(id).update(user) 里需要注意,Update 会自从 user 体中提取非 0 和非 nil 得作需要更新的内容, 因此, 如果需要更新一个 0, 此种方法将无法, 因此有种 : 1. 通添加 Cols 函数指定需要更新体中的些, 未指定的将不更新, 指定了的即使 0 也会更新 affected, err := engine.id(id).cols("age").update(&user) 2. 通入 map[string]interface{} 来行更新, 但需要外指定更新到个表, 因通 map 是无法自更新个表的 affected, err := engine.table(new(user)).id(id).update(map[string]interface{}{"age":0})

33 Version 要使用, 需要使用 version type User struct { Id int64 Name string Version int xorm:"version" } 在 Insert,version 的字段将会被置 1, 在 Update,Update 的内容必包含 version 原来的 var user User engine.id(1).get(&user) // SELECT * FROM user WHERE id =? engine.id(1).update(&user) // UPDATE user SET..., version = version + 1 WHERE id =? AND version =?

34 更新 Updated Updated 可以您在插入或每次更新自更新数据中的字段当前, 需要在 xorm 中使用 updated, 如下所示行, 的字段必 time.time 型 type User struct { Id int64 Name string UpdatedAt time.time `xorm:"updated"` } 在 Insert(), InsertOne(), Update() 方法被用,updated 的字段将会被自更新当前, 如下所示 : var user User engine.id(1).get(&user) // SELECT * FROM user WHERE id =? engine.id(1).update(&user) // UPDATE user SET..., updaetd_at =? WHERE id =?

35 除数据除数据 Delete 方法, 参数 struct 的指并且成条件 user := new(user) affected, err := engine.id(id).delete(user) Delete 的返回第一个参数除的数, 第二个参数注意 : 当除, 如果 user 中包含有 bool,float64 或者 float32 型, 有可能会使除失具体看 FAQ

36 除 Deleted Deleted 可以您不真正的除数据, 而是一个除使用此特性需要在 xorm 中使用 deleted, 如下所示行, 的字段必 time.time 型 type User struct { Id int64 Name string DeletedAt time.time `xorm:"deleted"` } 在 Delete(),deleted 的字段将会被自更新当前而不是去除条, 如下所示 : var user User engine.id(1).get(&user) // SELECT * FROM user WHERE id =? engine.id(1).delete(&user) // UPDATE user SET..., deleted_at =? WHERE id =? engine.id(1).get(&user) // 再次用 Get, 此将返回 false, nil, 即不存在 engine.id(1).delete(&user) // 再次用除会返回 0, nil, 即不存在那么如果已被除后, 要真正的得条或者真正的除条, 需要用 Unscoped, 如下所示 : var user User engine.id(1).unscoped().get(&user) // 此将可以得 engine.id(1).unscoped().delete(&user) // 此将可以真正的除

37 行 SQL 也可以直接行一个 SQL, 即 Select 命令在 Postgres 中支持原始 SQL 句中使用 ` 和? 符号 sql := "select * from userinfo" results, err := engine.query(sql) 当用 Query, 第一个返回 results []map[string][]byte 的形式

38 行 SQL 命令也可以直接行一个 SQL 命令, 即行 Insert, Update, Delete 等操作此不管数据是何种型, 都可以使用 ` 和? 符号 sql = "update `userinfo` set username=? where id=?" res, err := engine.exec(sql, "xiaolun", 1)

39 事理当使用事理, 需要建 Session 象在行事物理, 可以混用 ORM 方法和 RAW 方法, 如下代所示 : session := engine.newsession() defer session.close() // 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 } 注意如果您使用的是 mysql, 数据引擎 innodb 事才有效,myisam 引擎是不支持事的

40 存 xorm 内置了一致性存支持, 不默并没有开要开存, 需要在 engine 建完后行配置, 如 : 用一个全局的内存存 cacher := xorm.newlrucacher(xorm.newmemorystore(), 1000) engine.setdefaultcacher(cacher) 上述代采用了 LRU 算法的一个存, 存方式是存放到内存中, 存 struct 的数 1000 条, 存的范是所有具有主的表, 没有主的表中的数据将不会被存如果只想部分表, : cacher := xorm.newlrucacher(xorm.newmemorystore(), 1000) engine.mapcacher(&user, cacher) 如果要禁用某个表的存, : engine.mapcacher(&user, nil) 置完之后, 其它代基本上就不需要改了, 存系已在后台行当前了内存存的 CacheStore 接口 MemoryStore, 如果需要采用其它存, 可以 CacheStore 接口不需要特注意不适用存或者需要手的地方 : 1. 当使用了 Distinct, Having, GroupBy 方法将不会使用存 2. 在 Get 或者 Find 使用了 Cols, Omit 方法, 在开存后此方法无效, 系仍旧会取出个表中的所有字段 3. 在使用 Exec 方法行了方法之后, 可能会致存与数据不一致的地方因此如果用存, 尽量避免使用 Exec 如果必使用, 需要在使用了 Exec 之后用 ClearCache 手做存清除的工作比如 : engine.exec("update user set name =? where id =?", "xlw", 1) engine.clearcache(new(user)) 存的原理如下所示 :

41 事件 xorm 支持种方式的事件, 一种是在 Struct 中的特定方法来作事件的方法, 一种是在行句的程中行事件在 Struct 中作成方法的事件如下 : BeforeInsert() BeforeUpdate() BeforeDelete() func BeforeSet(name string, cell xorm.cell) 在 Get 或 Find 方法中, 当数据已从数据出来, 而在置到体之前用 AfterInsert() AfterUpdate() AfterDelete() 在句行程中的事件方法 : Before(beforeFunc interface{}) After(afterFunc interface{}) 其中 beforefunc 和 afterfunc 的原型 func(bean interface{}).

42 xorm 工具 xorm 是一数据操作命令行工具二制安装如果你安装了 got, 你可以入如下命令安装 : got go-xorm/cmd/xorm 或者你可以从 gobuild 下后解到可行路径源安装 go get github.com/go-xorm/cmd/xorm 同你需要安装如下依 : github.com/go-xorm/xorm Mysql: github.com/go-sql-driver/mysql MyMysql: github.com/ziutek/mymysql/godrv Postgres: github.com/lib/pq SQLite: github.com/mattn/go-sqlite3 ** 于 sqlite3 的支持, 你需要自己行 go build -tags sqlite3 因 sqlite3 需要 cgo 的支持命令列表有如下可用的命令 : reverse 反一个数据, 生成代 shell 通用的数据操作客端, 可数据和数据操作 dump Dump 数据中所有和数据到准出 source 从注入中行 SQL 文件 driver 列出所有支持的数据 reverse Reverse command is a tool to convert your database struct to all kinds languages of structs or classes. After you installed the tool, you can type xorm help reverse to get help example: sqlite: xorm reverse sqite3 test.db templates/goxorm mysql: xorm reverse mysql root:@/xorm_test?charset=utf8 templates/goxorm

43 mymysql: xorm reverse mymysql xorm_test2/root/ templates/goxorm postgres: xorm reverse postgres "dbname=xorm_test sslmode=disable" templates/goxorm will generated go files in./model directory Template and Config Now, xorm tool supports go and c++ two languages and have go, goxorm, c++ three of default templates. In template directory, we can put a config file to control how to generating. lang=go genjson=1 lang must be go or c++ now. genjson can be 1 or 0, if 1 then the struct will have json tag. Shell Shell command provides a tool to operate database. For example, you can create table, alter table, insert data, delete data and etc. xorm shell sqlite3 test.db will connect to the sqlite3 database and you can type help to list all the shell commands. Dump Dump command provides a tool to dump all database structs and data as SQL to your standard output. xorm dump sqlite3 test.db could dump sqlite3 database test.db to standard output. If you want to save to file, just type xorm dump sqlite3 test.db > test.sql. Source xorm source sqlite3 test.db < test.sql will execute sql file on the test.db. Driver List all supported drivers since default build will not include sqlite3. LICENSE BSD License

44 常怎么同使用 xorm 的 tag 和 json 的 tag? 答 : 使用空格 type User struct { Name string `json:"name" xorm:"name"` } 我的 struct 里面包含 bool 型, 什么它不能作条件也没法用 Update 更新? 答 : 默 bool 型因无法判断是否空, 所以不会自作条件也不会作 Update 的内容可以使用 UseBool 函数, 也可以使用 Cols 函数 engine.cols("bool_field").update(&struct{boolfield:true}) // UPDATE struct SET bool_field = true 我的 struct 里面包含 float64 和 float32 型, 什么用他作条件是不正确? 答 : 默 float32 和 float64 映射到数据中 float,real,double 几种型, 几种数据型数据的一般都是非精确的因此作相等条件有可能不会返回正确的果如果一定要作条件, 将数据中的型定 Numeric 或者 Decimal type account struct { money float64 `xorm:"numeric"` } 什么 Update Sqlite3 返回的 affected 和其它数据不一? 答 :Sqlite3 默 Update 返回的是 update 的条件的数条数, 不管是否真的有更新而 Mysql 和 Postgres 默情况下都是只返回中有字段改的数 xorm 有几种命名映射? 答 : 目前支持 SnakeMapper 和 SameMapper 种 SnakeMapper 支持体和成以峰式命名而数据表和字段以下划接命名 ;SameMapper 支持体和数据的命名保持一致的映射 xorm 支持复合主? 答 : 支持在定, 如果有多个字段了 pk, 些字段自成复合主, 序在 struct 中出的序在使用 Id 方法, 可以用 Id(xorm.PK{1, 2}) 的方式来用 xorm 如何使用 Join? 答 : 一般我配合 Join() 和 extends 来行, 比如我要个表行 Join 操作, 我可以 :

45 type Userinfo struct { Id int64 Name string DetailId int64 } type Userdetail struct { Id int64 Gender int } type User struct { Userinfo `xorm:"extends"` Userdetail `xorm:"extends"` } var users = make([]user, 0) err := engine.table(&userinfo{}).join("left", "userdetail", "userinfo.detail_id = userdetail.id").find(&users) 注意里的 Userinfo 在 User 中的位置必在 Userdetail 的前面, 因他在 join 句中的序在 userdetail 前面如果序不, 那么于同名的列, 有可能会出当然, 如果 Join 句比复, 我也可以直接用 Sql 函数 err := engine.sql("select * from userinfo, userdetail where userinfo.detail_id = userdetail.id").find(&users)

46 案例 Gogs - github.com/gogits/gogs Gowalker - github.com/unknwon/gowalker Gobuild.io - github.com/shxsun/gobuild Sudo China - github.com/insionng/toropress Godaily - github.com/govc/godaily GoCMS - github.com/zzboy/gocms GoBBS - gobbs.domolo.com go-blog - github.com/easykoo/go-blog

47 更新日志 v0.4.0 RC1 新特性 : 移 xorm cmd github.com/go-xorm/cmd 在重一般 DB 操作核心 github.com/go-xorm/core 移 github.com/xorm/tests github.com/go-xorm/tests 改 : Prepared statement 存添加 Incr API 指定区位置 v0.3.2 改 : Add AllCols & MustCols function Add TableName for custom table name Bug 修复 : v0.3.1 新特性 : 支持 MSSQL DB 通 ODBC (github.com/lunny/godbc); 通多个 pk 支持合主 ; 新增 Rows() API 用来遍果, 函数提供了似 sql.rows 的相似用法, 可作 Iterate() API 的可替代 ; ORM 体在允内建型的指作成, 使得数据 null 成可能 ; Before 和 After 支持改 : 允 int/int32/int64/uint/uint32/uint64/string 作主型函数 Get()/Find()/Iterate() 在性能上的改 v0.2.3 : 改善了文档 ; 提供了支持 ; 添加了区字段支持 ;Mapper 在分成表名 Mapper 和字段名 Mapper, 同了表或字段的自定前后 ;Insert 方法的返回含从 id, err 更改 affected, err, 大家注意 ; 添加了 UseBool 和 Distinct 函数

48 v0.2.2 : Postgres 新增了 lib/pq 的支持 ; 新增了逐条遍方法 Iterate; 新增了 SetMaxConns(go1.2+) 支持, 修复了 bug 若干 ; v0.2.1 : 新增数据反工具, 当前支持 go 和 c++ 代的生成, Xorm Tool README; 修复了一些 bug. v0.2.0 : 新增存支持, 速度提升 3-5 倍 ; 新增数据表和 Struct 同名的映射方式 ; 新增 Sync 同步表 ; v0.1.9 : 新增 postgres 和 mymysql 支持 ; 在 Postgres 中支持原始 SQL 句中使用 ` 和? 符号 ; 新增 Cols, StoreEngine, Charset 函数 ;SQL 句打印支持 io.writer 接口, 默打印到控制台 ; 新增更多的字段型支持, 映射 ; 除弃的 MakeSession 和 Create 函数 v0.1.8 : 新增合 index, 合 unique 支持, 看映射 v0.1.7 : 新增 IConnectPool 接口以及 NoneConnectPool, SysConnectPool, SimpleConnectPool 三种, 可以不使用接池, 使用系接池和使用自接池三种, 默 SysConnectPool, 即系自的接池同支持自定接池 Engine 新增 Close 方法, 在系退出用此方法 v0.1.6 : 新增 Conversion, 支持自定型到数据型的 ; 新增体自匿名成支持 ; 新增向映射支持 ; v0.1.5 : 新增多程的支持 ; 新增 Sql() 函数 ; 支持任意 sql 句的 struct ;Get 函数返回 ;MakeSession 和 Create 函数被 NewSession 和 NewEngine 函数替代 ; v0.1.4 : Get 函数和 Find 函数新增的入功能 ; 更多的数据型支持 v0.1.3 : Find 函数在支持入 Slice 或者 Map, 当入 Map,key id; 新增 Table 函数以多表和表行支持 v0.1.2 : Insert 函数支持混合 struct 和 slice 指入, 并根据数据型自批量插入, 同自添加事 v0.1.1 : 添加 Id, In 函数, 改善 README 文档 v0.1.0 : 初始化工程 s

通过Hive将数据写入到ElasticSearch

通过Hive将数据写入到ElasticSearch 我在使用 Hive 读取 ElasticSearch 中的数据文章中介绍了如何使用 Hive 读取 ElasticSearch 中的数据, 本文将接着上文继续介绍如何使用 Hive 将数据写入到 ElasticSearch 中在使用前同样需要加入 elasticsearch-hadoop-2.3.4.jar 依赖, 具体请参见前文介绍我们先在 Hive 里面建个名为 iteblog 的表,

xorm xorm 是一个 而强大的 Go 言 ORM. 通 它可以使数据 操作非常 便 xorm 的目 并不是 你完全不去学 SQL, 我 SQL 并不会 ORM 所替代, 但是 ORM 将可以解决 大部分的 SQL 需求 xorm 支持 种 格的混用 特性 支持 Struct 和数据 表之 的灵

xorm xorm 是一个而强大的 Go 言 ORM. 通它可以使数据操作非常便 xorm 的目并不是你完全不去学 SQL, 我 SQL 并不会 ORM 所替代, 但是 ORM 将可以解决大部分的 SQL 需求 xorm 支持种格的混用特性支持 Struct 和数据表之的灵