gen_table_column.go 3.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100
  1. // ============================================================================
  2. // This is auto-generated by gf cli tool only once. Fill this file as you wish.
  3. // ============================================================================
  4. package gen_table_column
  5. import (
  6. "github.com/gogf/gf/database/gdb"
  7. "github.com/gogf/gf/errors/gerror"
  8. "github.com/gogf/gf/frame/g"
  9. )
  10. //数据库字符串类型
  11. var COLUMNTYPE_STR = []string{"char", "varchar", "narchar", "varchar2", "tinytext", "text", "mediumtext", "longtext"}
  12. //数据库时间类型
  13. var COLUMNTYPE_TIME = []string{"datetime", "time", "date", "timestamp"}
  14. //数据库数字类型
  15. var COLUMNTYPE_NUMBER = []string{"tinyint", "smallint", "mediumint", "int", "number", "integer", "bigint", "float", "float", "double", "decimal"}
  16. //页面不需要编辑字段
  17. var COLUMNNAME_NOT_EDIT = []string{"id", "create_by", "create_time", "del_flag", "update_by", "update_time"}
  18. //页面不需要显示的列表字段
  19. var COLUMNNAME_NOT_LIST = []string{"id", "create_by", "create_time", "del_flag", "update_by", "update_time"}
  20. //页面不需要查询字段
  21. var COLUMNNAME_NOT_QUERY = []string{"id", "create_by", "create_time", "del_flag", "update_by", "update_time", "remark"}
  22. //根据表名称查询列信息
  23. func SelectDbTableColumnsByName(tableName string) ([]*Entity, error) {
  24. db := g.DB()
  25. var entity []*Entity
  26. sql := " select column_name, (case when (is_nullable = 'no' && column_key != 'PRI') then '1' else null end) as is_required, " +
  27. "(case when column_key = 'PRI' then '1' else '0' end) as is_pk, ordinal_position as sort, column_comment," +
  28. " (case when extra = 'auto_increment' then '1' else '0' end) as is_increment, column_type from information_schema.columns" +
  29. " where table_schema = (select database()) "
  30. sql += " and " + gdb.FormatSqlWithArgs(" table_name=? ", []interface{}{tableName}) + " order by ordinal_position ASC "
  31. result, err := db.GetAll(sql)
  32. if err != nil {
  33. g.Log().Error(err)
  34. return nil, gerror.New("查询列信息失败")
  35. }
  36. err = result.Structs(&entity)
  37. if err != nil {
  38. return nil, err
  39. }
  40. return entity, nil
  41. }
  42. //判断是否是数据库字符串类型
  43. func IsStringObject(value string) bool {
  44. return IsExistInArray(value, COLUMNTYPE_STR)
  45. }
  46. //判断是否是数据库时间类型
  47. func IsTimeObject(value string) bool {
  48. return IsExistInArray(value, COLUMNTYPE_TIME)
  49. }
  50. //判断是否是数据库数字类型
  51. func IsNumberObject(value string) bool {
  52. return IsExistInArray(value, COLUMNTYPE_NUMBER)
  53. }
  54. //页面不需要编辑字段
  55. func IsNotEdit(value string) bool {
  56. return !IsExistInArray(value, COLUMNNAME_NOT_EDIT)
  57. }
  58. //页面不需要显示的列表字段
  59. func IsNotList(value string) bool {
  60. return !IsExistInArray(value, COLUMNNAME_NOT_LIST)
  61. }
  62. //页面不需要查询字段
  63. func IsNotQuery(value string) bool {
  64. return !IsExistInArray(value, COLUMNNAME_NOT_QUERY)
  65. }
  66. //判断string 是否存在在数组中
  67. func IsExistInArray(value string, array []string) bool {
  68. for _, v := range array {
  69. if v == value {
  70. return true
  71. }
  72. }
  73. return false
  74. }
  75. //查询业务字段列表
  76. func SelectGenTableColumnListByTableId(tableId int64) ([]*Entity, error) {
  77. list, err := Model.Where(Columns.TableId, tableId).Order(Columns.Sort + " asc, " + Columns.ColumnId + " asc").All()
  78. if err != nil {
  79. g.Log().Error(err)
  80. return nil, gerror.New("获取字段信息出错")
  81. }
  82. return list, nil
  83. }