flow_model.go 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359
  1. // ==========================================================================
  2. // This is auto-generated by gf cli tool. You may not really want to edit it.
  3. // ==========================================================================
  4. package wf_flow
  5. import (
  6. "database/sql"
  7. "github.com/gogf/gf/database/gdb"
  8. "github.com/gogf/gf/frame/g"
  9. "github.com/gogf/gf/frame/gmvc"
  10. "time"
  11. )
  12. // arModel is a active record design model for table wf_flow operations.
  13. type arModel struct {
  14. gmvc.M
  15. }
  16. var (
  17. // Table is the table name of wf_flow.
  18. Table = "wf_flow"
  19. // Model is the model object of wf_flow.
  20. Model = &arModel{g.DB("default").Table(Table).Safe()}
  21. // Columns defines and stores column names for table wf_flow.
  22. Columns = struct {
  23. Id string //
  24. Type string // 流程类别
  25. FlowName string // 流程名称
  26. FlowDesc string // 描述
  27. SortOrder string // 排序
  28. Status string // 0不可用1正常
  29. IsDel string //
  30. Uid string // 添加用户
  31. AddTime string // 添加时间
  32. }{
  33. Id: "id",
  34. Type: "type",
  35. FlowName: "flow_name",
  36. FlowDesc: "flow_desc",
  37. SortOrder: "sort_order",
  38. Status: "status",
  39. IsDel: "is_del",
  40. Uid: "uid",
  41. AddTime: "add_time",
  42. }
  43. )
  44. // FindOne is a convenience method for Model.FindOne.
  45. // See Model.FindOne.
  46. func FindOne(where ...interface{}) (*Entity, error) {
  47. return Model.FindOne(where...)
  48. }
  49. // FindAll is a convenience method for Model.FindAll.
  50. // See Model.FindAll.
  51. func FindAll(where ...interface{}) ([]*Entity, error) {
  52. return Model.FindAll(where...)
  53. }
  54. // FindValue is a convenience method for Model.FindValue.
  55. // See Model.FindValue.
  56. func FindValue(fieldsAndWhere ...interface{}) (gdb.Value, error) {
  57. return Model.FindValue(fieldsAndWhere...)
  58. }
  59. // FindArray is a convenience method for Model.FindArray.
  60. // See Model.FindArray.
  61. func FindArray(fieldsAndWhere ...interface{}) ([]gdb.Value, error) {
  62. return Model.FindArray(fieldsAndWhere...)
  63. }
  64. // FindCount is a convenience method for Model.FindCount.
  65. // See Model.FindCount.
  66. func FindCount(where ...interface{}) (int, error) {
  67. return Model.FindCount(where...)
  68. }
  69. // Insert is a convenience method for Model.Insert.
  70. func Insert(data ...interface{}) (result sql.Result, err error) {
  71. return Model.Insert(data...)
  72. }
  73. // InsertIgnore is a convenience method for Model.InsertIgnore.
  74. func InsertIgnore(data ...interface{}) (result sql.Result, err error) {
  75. return Model.InsertIgnore(data...)
  76. }
  77. // Replace is a convenience method for Model.Replace.
  78. func Replace(data ...interface{}) (result sql.Result, err error) {
  79. return Model.Replace(data...)
  80. }
  81. // Save is a convenience method for Model.Save.
  82. func Save(data ...interface{}) (result sql.Result, err error) {
  83. return Model.Save(data...)
  84. }
  85. // Update is a convenience method for Model.Update.
  86. func Update(dataAndWhere ...interface{}) (result sql.Result, err error) {
  87. return Model.Update(dataAndWhere...)
  88. }
  89. // Delete is a convenience method for Model.Delete.
  90. func Delete(where ...interface{}) (result sql.Result, err error) {
  91. return Model.Delete(where...)
  92. }
  93. // As sets an alias name for current table.
  94. func (m *arModel) As(as string) *arModel {
  95. return &arModel{m.M.As(as)}
  96. }
  97. // TX sets the transaction for current operation.
  98. func (m *arModel) TX(tx *gdb.TX) *arModel {
  99. return &arModel{m.M.TX(tx)}
  100. }
  101. // Master marks the following operation on master node.
  102. func (m *arModel) Master() *arModel {
  103. return &arModel{m.M.Master()}
  104. }
  105. // Slave marks the following operation on slave node.
  106. // Note that it makes sense only if there's any slave node configured.
  107. func (m *arModel) Slave() *arModel {
  108. return &arModel{m.M.Slave()}
  109. }
  110. // LeftJoin does "LEFT JOIN ... ON ..." statement on the model.
  111. // The parameter <table> can be joined table and its joined condition,
  112. // and also with its alias name, like:
  113. // Table("user").LeftJoin("user_detail", "user_detail.uid=user.uid")
  114. // Table("user", "u").LeftJoin("user_detail", "ud", "ud.uid=u.uid")
  115. func (m *arModel) LeftJoin(table ...string) *arModel {
  116. return &arModel{m.M.LeftJoin(table...)}
  117. }
  118. // RightJoin does "RIGHT JOIN ... ON ..." statement on the model.
  119. // The parameter <table> can be joined table and its joined condition,
  120. // and also with its alias name, like:
  121. // Table("user").RightJoin("user_detail", "user_detail.uid=user.uid")
  122. // Table("user", "u").RightJoin("user_detail", "ud", "ud.uid=u.uid")
  123. func (m *arModel) RightJoin(table ...string) *arModel {
  124. return &arModel{m.M.RightJoin(table...)}
  125. }
  126. // InnerJoin does "INNER JOIN ... ON ..." statement on the model.
  127. // The parameter <table> can be joined table and its joined condition,
  128. // and also with its alias name, like:
  129. // Table("user").InnerJoin("user_detail", "user_detail.uid=user.uid")
  130. // Table("user", "u").InnerJoin("user_detail", "ud", "ud.uid=u.uid")
  131. func (m *arModel) InnerJoin(table ...string) *arModel {
  132. return &arModel{m.M.InnerJoin(table...)}
  133. }
  134. // Fields sets the operation fields of the model, multiple fields joined using char ','.
  135. func (m *arModel) Fields(fields string) *arModel {
  136. return &arModel{m.M.Fields(fields)}
  137. }
  138. // FieldsEx sets the excluded operation fields of the model, multiple fields joined using char ','.
  139. func (m *arModel) FieldsEx(fields string) *arModel {
  140. return &arModel{m.M.FieldsEx(fields)}
  141. }
  142. // Option sets the extra operation option for the model.
  143. func (m *arModel) Option(option int) *arModel {
  144. return &arModel{m.M.Option(option)}
  145. }
  146. // OmitEmpty sets OPTION_OMITEMPTY option for the model, which automatically filers
  147. // the data and where attributes for empty values.
  148. func (m *arModel) OmitEmpty() *arModel {
  149. return &arModel{m.M.OmitEmpty()}
  150. }
  151. // Filter marks filtering the fields which does not exist in the fields of the operated table.
  152. func (m *arModel) Filter() *arModel {
  153. return &arModel{m.M.Filter()}
  154. }
  155. // Where sets the condition statement for the model. The parameter <where> can be type of
  156. // string/map/gmap/slice/struct/*struct, etc. Note that, if it's called more than one times,
  157. // multiple conditions will be joined into where statement using "AND".
  158. // Eg:
  159. // Where("uid=10000")
  160. // Where("uid", 10000)
  161. // Where("money>? AND name like ?", 99999, "vip_%")
  162. // Where("uid", 1).Where("name", "john")
  163. // Where("status IN (?)", g.Slice{1,2,3})
  164. // Where("age IN(?,?)", 18, 50)
  165. // Where(User{ Id : 1, UserName : "john"})
  166. func (m *arModel) Where(where interface{}, args ...interface{}) *arModel {
  167. return &arModel{m.M.Where(where, args...)}
  168. }
  169. // And adds "AND" condition to the where statement.
  170. func (m *arModel) And(where interface{}, args ...interface{}) *arModel {
  171. return &arModel{m.M.And(where, args...)}
  172. }
  173. // Or adds "OR" condition to the where statement.
  174. func (m *arModel) Or(where interface{}, args ...interface{}) *arModel {
  175. return &arModel{m.M.Or(where, args...)}
  176. }
  177. // Group sets the "GROUP BY" statement for the model.
  178. func (m *arModel) Group(groupBy string) *arModel {
  179. return &arModel{m.M.Group(groupBy)}
  180. }
  181. // Order sets the "ORDER BY" statement for the model.
  182. func (m *arModel) Order(orderBy ...string) *arModel {
  183. return &arModel{m.M.Order(orderBy...)}
  184. }
  185. // Limit sets the "LIMIT" statement for the model.
  186. // The parameter <limit> can be either one or two number, if passed two number is passed,
  187. // it then sets "LIMIT limit[0],limit[1]" statement for the model, or else it sets "LIMIT limit[0]"
  188. // statement.
  189. func (m *arModel) Limit(limit ...int) *arModel {
  190. return &arModel{m.M.Limit(limit...)}
  191. }
  192. // Offset sets the "OFFSET" statement for the model.
  193. // It only makes sense for some databases like SQLServer, PostgreSQL, etc.
  194. func (m *arModel) Offset(offset int) *arModel {
  195. return &arModel{m.M.Offset(offset)}
  196. }
  197. // Page sets the paging number for the model.
  198. // The parameter <page> is started from 1 for paging.
  199. // Note that, it differs that the Limit function start from 0 for "LIMIT" statement.
  200. func (m *arModel) Page(page, limit int) *arModel {
  201. return &arModel{m.M.Page(page, limit)}
  202. }
  203. // Batch sets the batch operation number for the model.
  204. func (m *arModel) Batch(batch int) *arModel {
  205. return &arModel{m.M.Batch(batch)}
  206. }
  207. // Cache sets the cache feature for the model. It caches the result of the sql, which means
  208. // if there's another same sql request, it just reads and returns the result from cache, it
  209. // but not committed and executed into the database.
  210. //
  211. // If the parameter <duration> < 0, which means it clear the cache with given <name>.
  212. // If the parameter <duration> = 0, which means it never expires.
  213. // If the parameter <duration> > 0, which means it expires after <duration>.
  214. //
  215. // The optional parameter <name> is used to bind a name to the cache, which means you can later
  216. // control the cache like changing the <duration> or clearing the cache with specified <name>.
  217. //
  218. // Note that, the cache feature is disabled if the model is operating on a transaction.
  219. func (m *arModel) Cache(duration time.Duration, name ...string) *arModel {
  220. return &arModel{m.M.Cache(duration, name...)}
  221. }
  222. // Data sets the operation data for the model.
  223. // The parameter <data> can be type of string/map/gmap/slice/struct/*struct, etc.
  224. // Eg:
  225. // Data("uid=10000")
  226. // Data("uid", 10000)
  227. // Data(g.Map{"uid": 10000, "name":"john"})
  228. // Data(g.Slice{g.Map{"uid": 10000, "name":"john"}, g.Map{"uid": 20000, "name":"smith"})
  229. func (m *arModel) Data(data ...interface{}) *arModel {
  230. return &arModel{m.M.Data(data...)}
  231. }
  232. // All does "SELECT FROM ..." statement for the model.
  233. // It retrieves the records from table and returns the result as []*Entity.
  234. // It returns nil if there's no record retrieved with the given conditions from table.
  235. //
  236. // The optional parameter <where> is the same as the parameter of Model.Where function,
  237. // see Model.Where.
  238. func (m *arModel) All(where ...interface{}) ([]*Entity, error) {
  239. all, err := m.M.All(where...)
  240. if err != nil {
  241. return nil, err
  242. }
  243. var entities []*Entity
  244. if err = all.Structs(&entities); err != nil && err != sql.ErrNoRows {
  245. return nil, err
  246. }
  247. return entities, nil
  248. }
  249. // One retrieves one record from table and returns the result as *Entity.
  250. // It returns nil if there's no record retrieved with the given conditions from table.
  251. //
  252. // The optional parameter <where> is the same as the parameter of Model.Where function,
  253. // see Model.Where.
  254. func (m *arModel) One(where ...interface{}) (*Entity, error) {
  255. one, err := m.M.One(where...)
  256. if err != nil {
  257. return nil, err
  258. }
  259. var entity *Entity
  260. if err = one.Struct(&entity); err != nil && err != sql.ErrNoRows {
  261. return nil, err
  262. }
  263. return entity, nil
  264. }
  265. // FindOne retrieves and returns a single Record by Model.WherePri and Model.One.
  266. // Also see Model.WherePri and Model.One.
  267. func (m *arModel) FindOne(where ...interface{}) (*Entity, error) {
  268. one, err := m.M.FindOne(where...)
  269. if err != nil {
  270. return nil, err
  271. }
  272. var entity *Entity
  273. if err = one.Struct(&entity); err != nil && err != sql.ErrNoRows {
  274. return nil, err
  275. }
  276. return entity, nil
  277. }
  278. // FindAll retrieves and returns Result by by Model.WherePri and Model.All.
  279. // Also see Model.WherePri and Model.All.
  280. func (m *arModel) FindAll(where ...interface{}) ([]*Entity, error) {
  281. all, err := m.M.FindAll(where...)
  282. if err != nil {
  283. return nil, err
  284. }
  285. var entities []*Entity
  286. if err = all.Structs(&entities); err != nil && err != sql.ErrNoRows {
  287. return nil, err
  288. }
  289. return entities, nil
  290. }
  291. // Chunk iterates the table with given size and callback function.
  292. func (m *arModel) Chunk(limit int, callback func(entities []*Entity, err error) bool) {
  293. m.M.Chunk(limit, func(result gdb.Result, err error) bool {
  294. var entities []*Entity
  295. err = result.Structs(&entities)
  296. if err == sql.ErrNoRows {
  297. return false
  298. }
  299. return callback(entities, err)
  300. })
  301. }
  302. // LockUpdate sets the lock for update for current operation.
  303. func (m *arModel) LockUpdate() *arModel {
  304. return &arModel{m.M.LockUpdate()}
  305. }
  306. // LockShared sets the lock in share mode for current operation.
  307. func (m *arModel) LockShared() *arModel {
  308. return &arModel{m.M.LockShared()}
  309. }
  310. // Unscoped enables/disables the soft deleting feature.
  311. func (m *arModel) Unscoped() *arModel {
  312. return &arModel{m.M.Unscoped()}
  313. }