server.gen.go 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412
  1. // Code generated by gorm.io/gen. DO NOT EDIT.
  2. // Code generated by gorm.io/gen. DO NOT EDIT.
  3. // Code generated by gorm.io/gen. DO NOT EDIT.
  4. package query
  5. import (
  6. "context"
  7. "gorm.io/gorm"
  8. "gorm.io/gorm/clause"
  9. "gorm.io/gorm/schema"
  10. "gorm.io/gen"
  11. "gorm.io/gen/field"
  12. "gorm.io/plugin/dbresolver"
  13. "wechat-api/database/dao/wechat/model"
  14. )
  15. func newServer(db *gorm.DB, opts ...gen.DOOption) server {
  16. _server := server{}
  17. _server.serverDo.UseDB(db, opts...)
  18. _server.serverDo.UseModel(&model.Server{})
  19. tableName := _server.serverDo.TableName()
  20. _server.ALL = field.NewAsterisk(tableName)
  21. _server.ID = field.NewInt64(tableName, "id")
  22. _server.CreatedAt = field.NewTime(tableName, "created_at")
  23. _server.UpdatedAt = field.NewTime(tableName, "updated_at")
  24. _server.Status = field.NewInt64(tableName, "status")
  25. _server.DeletedAt = field.NewField(tableName, "deleted_at")
  26. _server.Name = field.NewString(tableName, "name")
  27. _server.PublicIP = field.NewString(tableName, "public_ip")
  28. _server.PrivateIP = field.NewString(tableName, "private_ip")
  29. _server.AdminPort = field.NewString(tableName, "admin_port")
  30. _server.fillFieldMap()
  31. return _server
  32. }
  33. type server struct {
  34. serverDo
  35. ALL field.Asterisk
  36. ID field.Int64
  37. CreatedAt field.Time // Create Time | 创建日期
  38. UpdatedAt field.Time // Update Time | 修改日期
  39. Status field.Int64 // Status 1: normal 2: ban | 状态 1 正常 2 禁用
  40. DeletedAt field.Field // Delete Time | 删除日期
  41. Name field.String // 名称
  42. PublicIP field.String // 公网ip
  43. PrivateIP field.String // 内网ip
  44. AdminPort field.String // 管理端口
  45. fieldMap map[string]field.Expr
  46. }
  47. func (s server) Table(newTableName string) *server {
  48. s.serverDo.UseTable(newTableName)
  49. return s.updateTableName(newTableName)
  50. }
  51. func (s server) As(alias string) *server {
  52. s.serverDo.DO = *(s.serverDo.As(alias).(*gen.DO))
  53. return s.updateTableName(alias)
  54. }
  55. func (s *server) updateTableName(table string) *server {
  56. s.ALL = field.NewAsterisk(table)
  57. s.ID = field.NewInt64(table, "id")
  58. s.CreatedAt = field.NewTime(table, "created_at")
  59. s.UpdatedAt = field.NewTime(table, "updated_at")
  60. s.Status = field.NewInt64(table, "status")
  61. s.DeletedAt = field.NewField(table, "deleted_at")
  62. s.Name = field.NewString(table, "name")
  63. s.PublicIP = field.NewString(table, "public_ip")
  64. s.PrivateIP = field.NewString(table, "private_ip")
  65. s.AdminPort = field.NewString(table, "admin_port")
  66. s.fillFieldMap()
  67. return s
  68. }
  69. func (s *server) GetFieldByName(fieldName string) (field.OrderExpr, bool) {
  70. _f, ok := s.fieldMap[fieldName]
  71. if !ok || _f == nil {
  72. return nil, false
  73. }
  74. _oe, ok := _f.(field.OrderExpr)
  75. return _oe, ok
  76. }
  77. func (s *server) fillFieldMap() {
  78. s.fieldMap = make(map[string]field.Expr, 9)
  79. s.fieldMap["id"] = s.ID
  80. s.fieldMap["created_at"] = s.CreatedAt
  81. s.fieldMap["updated_at"] = s.UpdatedAt
  82. s.fieldMap["status"] = s.Status
  83. s.fieldMap["deleted_at"] = s.DeletedAt
  84. s.fieldMap["name"] = s.Name
  85. s.fieldMap["public_ip"] = s.PublicIP
  86. s.fieldMap["private_ip"] = s.PrivateIP
  87. s.fieldMap["admin_port"] = s.AdminPort
  88. }
  89. func (s server) clone(db *gorm.DB) server {
  90. s.serverDo.ReplaceConnPool(db.Statement.ConnPool)
  91. return s
  92. }
  93. func (s server) replaceDB(db *gorm.DB) server {
  94. s.serverDo.ReplaceDB(db)
  95. return s
  96. }
  97. type serverDo struct{ gen.DO }
  98. type IServerDo interface {
  99. gen.SubQuery
  100. Debug() IServerDo
  101. WithContext(ctx context.Context) IServerDo
  102. WithResult(fc func(tx gen.Dao)) gen.ResultInfo
  103. ReplaceDB(db *gorm.DB)
  104. ReadDB() IServerDo
  105. WriteDB() IServerDo
  106. As(alias string) gen.Dao
  107. Session(config *gorm.Session) IServerDo
  108. Columns(cols ...field.Expr) gen.Columns
  109. Clauses(conds ...clause.Expression) IServerDo
  110. Not(conds ...gen.Condition) IServerDo
  111. Or(conds ...gen.Condition) IServerDo
  112. Select(conds ...field.Expr) IServerDo
  113. Where(conds ...gen.Condition) IServerDo
  114. Order(conds ...field.Expr) IServerDo
  115. Distinct(cols ...field.Expr) IServerDo
  116. Omit(cols ...field.Expr) IServerDo
  117. Join(table schema.Tabler, on ...field.Expr) IServerDo
  118. LeftJoin(table schema.Tabler, on ...field.Expr) IServerDo
  119. RightJoin(table schema.Tabler, on ...field.Expr) IServerDo
  120. Group(cols ...field.Expr) IServerDo
  121. Having(conds ...gen.Condition) IServerDo
  122. Limit(limit int) IServerDo
  123. Offset(offset int) IServerDo
  124. Count() (count int64, err error)
  125. Scopes(funcs ...func(gen.Dao) gen.Dao) IServerDo
  126. Unscoped() IServerDo
  127. Create(values ...*model.Server) error
  128. CreateInBatches(values []*model.Server, batchSize int) error
  129. Save(values ...*model.Server) error
  130. First() (*model.Server, error)
  131. Take() (*model.Server, error)
  132. Last() (*model.Server, error)
  133. Find() ([]*model.Server, error)
  134. FindInBatch(batchSize int, fc func(tx gen.Dao, batch int) error) (results []*model.Server, err error)
  135. FindInBatches(result *[]*model.Server, batchSize int, fc func(tx gen.Dao, batch int) error) error
  136. Pluck(column field.Expr, dest interface{}) error
  137. Delete(...*model.Server) (info gen.ResultInfo, err error)
  138. Update(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
  139. UpdateSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
  140. Updates(value interface{}) (info gen.ResultInfo, err error)
  141. UpdateColumn(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
  142. UpdateColumnSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
  143. UpdateColumns(value interface{}) (info gen.ResultInfo, err error)
  144. UpdateFrom(q gen.SubQuery) gen.Dao
  145. Attrs(attrs ...field.AssignExpr) IServerDo
  146. Assign(attrs ...field.AssignExpr) IServerDo
  147. Joins(fields ...field.RelationField) IServerDo
  148. Preload(fields ...field.RelationField) IServerDo
  149. FirstOrInit() (*model.Server, error)
  150. FirstOrCreate() (*model.Server, error)
  151. FindByPage(offset int, limit int) (result []*model.Server, count int64, err error)
  152. ScanByPage(result interface{}, offset int, limit int) (count int64, err error)
  153. Scan(result interface{}) (err error)
  154. Returning(value interface{}, columns ...string) IServerDo
  155. UnderlyingDB() *gorm.DB
  156. schema.Tabler
  157. }
  158. func (s serverDo) Debug() IServerDo {
  159. return s.withDO(s.DO.Debug())
  160. }
  161. func (s serverDo) WithContext(ctx context.Context) IServerDo {
  162. return s.withDO(s.DO.WithContext(ctx))
  163. }
  164. func (s serverDo) ReadDB() IServerDo {
  165. return s.Clauses(dbresolver.Read)
  166. }
  167. func (s serverDo) WriteDB() IServerDo {
  168. return s.Clauses(dbresolver.Write)
  169. }
  170. func (s serverDo) Session(config *gorm.Session) IServerDo {
  171. return s.withDO(s.DO.Session(config))
  172. }
  173. func (s serverDo) Clauses(conds ...clause.Expression) IServerDo {
  174. return s.withDO(s.DO.Clauses(conds...))
  175. }
  176. func (s serverDo) Returning(value interface{}, columns ...string) IServerDo {
  177. return s.withDO(s.DO.Returning(value, columns...))
  178. }
  179. func (s serverDo) Not(conds ...gen.Condition) IServerDo {
  180. return s.withDO(s.DO.Not(conds...))
  181. }
  182. func (s serverDo) Or(conds ...gen.Condition) IServerDo {
  183. return s.withDO(s.DO.Or(conds...))
  184. }
  185. func (s serverDo) Select(conds ...field.Expr) IServerDo {
  186. return s.withDO(s.DO.Select(conds...))
  187. }
  188. func (s serverDo) Where(conds ...gen.Condition) IServerDo {
  189. return s.withDO(s.DO.Where(conds...))
  190. }
  191. func (s serverDo) Order(conds ...field.Expr) IServerDo {
  192. return s.withDO(s.DO.Order(conds...))
  193. }
  194. func (s serverDo) Distinct(cols ...field.Expr) IServerDo {
  195. return s.withDO(s.DO.Distinct(cols...))
  196. }
  197. func (s serverDo) Omit(cols ...field.Expr) IServerDo {
  198. return s.withDO(s.DO.Omit(cols...))
  199. }
  200. func (s serverDo) Join(table schema.Tabler, on ...field.Expr) IServerDo {
  201. return s.withDO(s.DO.Join(table, on...))
  202. }
  203. func (s serverDo) LeftJoin(table schema.Tabler, on ...field.Expr) IServerDo {
  204. return s.withDO(s.DO.LeftJoin(table, on...))
  205. }
  206. func (s serverDo) RightJoin(table schema.Tabler, on ...field.Expr) IServerDo {
  207. return s.withDO(s.DO.RightJoin(table, on...))
  208. }
  209. func (s serverDo) Group(cols ...field.Expr) IServerDo {
  210. return s.withDO(s.DO.Group(cols...))
  211. }
  212. func (s serverDo) Having(conds ...gen.Condition) IServerDo {
  213. return s.withDO(s.DO.Having(conds...))
  214. }
  215. func (s serverDo) Limit(limit int) IServerDo {
  216. return s.withDO(s.DO.Limit(limit))
  217. }
  218. func (s serverDo) Offset(offset int) IServerDo {
  219. return s.withDO(s.DO.Offset(offset))
  220. }
  221. func (s serverDo) Scopes(funcs ...func(gen.Dao) gen.Dao) IServerDo {
  222. return s.withDO(s.DO.Scopes(funcs...))
  223. }
  224. func (s serverDo) Unscoped() IServerDo {
  225. return s.withDO(s.DO.Unscoped())
  226. }
  227. func (s serverDo) Create(values ...*model.Server) error {
  228. if len(values) == 0 {
  229. return nil
  230. }
  231. return s.DO.Create(values)
  232. }
  233. func (s serverDo) CreateInBatches(values []*model.Server, batchSize int) error {
  234. return s.DO.CreateInBatches(values, batchSize)
  235. }
  236. // Save : !!! underlying implementation is different with GORM
  237. // The method is equivalent to executing the statement: db.Clauses(clause.OnConflict{UpdateAll: true}).Create(values)
  238. func (s serverDo) Save(values ...*model.Server) error {
  239. if len(values) == 0 {
  240. return nil
  241. }
  242. return s.DO.Save(values)
  243. }
  244. func (s serverDo) First() (*model.Server, error) {
  245. if result, err := s.DO.First(); err != nil {
  246. return nil, err
  247. } else {
  248. return result.(*model.Server), nil
  249. }
  250. }
  251. func (s serverDo) Take() (*model.Server, error) {
  252. if result, err := s.DO.Take(); err != nil {
  253. return nil, err
  254. } else {
  255. return result.(*model.Server), nil
  256. }
  257. }
  258. func (s serverDo) Last() (*model.Server, error) {
  259. if result, err := s.DO.Last(); err != nil {
  260. return nil, err
  261. } else {
  262. return result.(*model.Server), nil
  263. }
  264. }
  265. func (s serverDo) Find() ([]*model.Server, error) {
  266. result, err := s.DO.Find()
  267. return result.([]*model.Server), err
  268. }
  269. func (s serverDo) FindInBatch(batchSize int, fc func(tx gen.Dao, batch int) error) (results []*model.Server, err error) {
  270. buf := make([]*model.Server, 0, batchSize)
  271. err = s.DO.FindInBatches(&buf, batchSize, func(tx gen.Dao, batch int) error {
  272. defer func() { results = append(results, buf...) }()
  273. return fc(tx, batch)
  274. })
  275. return results, err
  276. }
  277. func (s serverDo) FindInBatches(result *[]*model.Server, batchSize int, fc func(tx gen.Dao, batch int) error) error {
  278. return s.DO.FindInBatches(result, batchSize, fc)
  279. }
  280. func (s serverDo) Attrs(attrs ...field.AssignExpr) IServerDo {
  281. return s.withDO(s.DO.Attrs(attrs...))
  282. }
  283. func (s serverDo) Assign(attrs ...field.AssignExpr) IServerDo {
  284. return s.withDO(s.DO.Assign(attrs...))
  285. }
  286. func (s serverDo) Joins(fields ...field.RelationField) IServerDo {
  287. for _, _f := range fields {
  288. s = *s.withDO(s.DO.Joins(_f))
  289. }
  290. return &s
  291. }
  292. func (s serverDo) Preload(fields ...field.RelationField) IServerDo {
  293. for _, _f := range fields {
  294. s = *s.withDO(s.DO.Preload(_f))
  295. }
  296. return &s
  297. }
  298. func (s serverDo) FirstOrInit() (*model.Server, error) {
  299. if result, err := s.DO.FirstOrInit(); err != nil {
  300. return nil, err
  301. } else {
  302. return result.(*model.Server), nil
  303. }
  304. }
  305. func (s serverDo) FirstOrCreate() (*model.Server, error) {
  306. if result, err := s.DO.FirstOrCreate(); err != nil {
  307. return nil, err
  308. } else {
  309. return result.(*model.Server), nil
  310. }
  311. }
  312. func (s serverDo) FindByPage(offset int, limit int) (result []*model.Server, count int64, err error) {
  313. result, err = s.Offset(offset).Limit(limit).Find()
  314. if err != nil {
  315. return
  316. }
  317. if size := len(result); 0 < limit && 0 < size && size < limit {
  318. count = int64(size + offset)
  319. return
  320. }
  321. count, err = s.Offset(-1).Limit(-1).Count()
  322. return
  323. }
  324. func (s serverDo) ScanByPage(result interface{}, offset int, limit int) (count int64, err error) {
  325. count, err = s.Count()
  326. if err != nil {
  327. return
  328. }
  329. err = s.Offset(offset).Limit(limit).Scan(result)
  330. return
  331. }
  332. func (s serverDo) Scan(result interface{}) (err error) {
  333. return s.DO.Scan(result)
  334. }
  335. func (s serverDo) Delete(models ...*model.Server) (result gen.ResultInfo, err error) {
  336. return s.DO.Delete(models)
  337. }
  338. func (s *serverDo) withDO(do gen.Dao) *serverDo {
  339. s.DO = *do.(*gen.DO)
  340. return s
  341. }