db.go 2.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120
  1. package models
  2. import (
  3. _ "github.com/go-sql-driver/mysql"
  4. "hongze/hongze_ETA_mobile_api/models/data_manage"
  5. "hongze/hongze_ETA_mobile_api/models/system"
  6. "hongze/hongze_ETA_mobile_api/utils"
  7. "time"
  8. "github.com/beego/beego/v2/client/orm"
  9. )
  10. func init() {
  11. _ = orm.RegisterDataBase("default", "mysql", utils.MYSQL_URL)
  12. orm.SetMaxIdleConns("default", 50)
  13. orm.SetMaxOpenConns("default", 100)
  14. db, _ := orm.GetDB("default")
  15. db.SetConnMaxLifetime(10 * time.Minute)
  16. _ = orm.RegisterDataBase("rddp", "mysql", utils.MYSQL_URL_RDDP)
  17. orm.SetMaxIdleConns("rddp", 50)
  18. orm.SetMaxOpenConns("rddp", 100)
  19. report_db, _ := orm.GetDB("rddp")
  20. report_db.SetConnMaxLifetime(10 * time.Minute)
  21. _ = orm.RegisterDataBase("edb", "mysql", utils.MYSQL_URL_EDB)
  22. orm.SetMaxIdleConns("edb", 50)
  23. orm.SetMaxOpenConns("edb", 100)
  24. edb_db, _ := orm.GetDB("edb")
  25. edb_db.SetConnMaxLifetime(10 * time.Minute)
  26. _ = orm.RegisterDataBase("data", "mysql", utils.MYSQL_URL_DATA)
  27. orm.SetMaxIdleConns("data", 50)
  28. orm.SetMaxOpenConns("data", 100)
  29. data_db, _ := orm.GetDB("data")
  30. data_db.SetConnMaxLifetime(10 * time.Minute)
  31. _ = orm.RegisterDataBase("gl", "mysql", utils.MYSQL_URL_GL)
  32. orm.SetMaxIdleConns("gl", 50)
  33. orm.SetMaxOpenConns("gl", 100)
  34. gl, _ := orm.GetDB("gl")
  35. gl.SetConnMaxLifetime(10 * time.Minute)
  36. _ = orm.RegisterDataBase("comein_data", "mysql", utils.MYSQL_URL_COMEIN_DATA)
  37. orm.SetMaxIdleConns("comein_data", 50)
  38. orm.SetMaxOpenConns("comein_data", 100)
  39. comein_datadb, _ := orm.GetDB("comein_data")
  40. comein_datadb.SetConnMaxLifetime(10 * time.Minute)
  41. orm.Debug = true
  42. orm.DebugLog = orm.NewLog(utils.Binlog)
  43. //注册对象
  44. orm.RegisterModel(
  45. new(Classify),
  46. new(Ppt),
  47. new(PptPages),
  48. new(PptPublishRecord),
  49. new(PptV2),
  50. new(PptV2PublishRecord),
  51. new(PptV2SaveLog),
  52. new(PptV2Group),
  53. new(PptV2GroupMapping),
  54. new(PptV2Grant), //ppt授权操作表
  55. )
  56. // 报告相关 数据表
  57. initReport()
  58. initSystem()
  59. initChart()
  60. initEdbData()
  61. }
  62. // initSystem 系统表 数据表
  63. func initSystem() {
  64. orm.RegisterModel(
  65. new(system.SysUserLoginRecord),
  66. new(system.SysSession),
  67. new(system.Admin),
  68. )
  69. }
  70. // initReport 报告相关 数据表
  71. func initReport() {
  72. orm.RegisterModel(
  73. new(ClassifyMenu), // 报告分类-子目录表
  74. )
  75. }
  76. // initChart 图表 数据表
  77. func initChart() {
  78. orm.RegisterModel(
  79. new(data_manage.ChartClassify),
  80. new(data_manage.ChartInfo),
  81. new(data_manage.ChartEdbMapping),
  82. new(data_manage.MyChartClassify),
  83. new(data_manage.MyChart),
  84. new(data_manage.MyChartLog),
  85. new(data_manage.MyChartClassifyMapping),
  86. //new(data_manage.ChartInfoLog),
  87. new(data_manage.ChartInfoCorrelation),
  88. )
  89. }
  90. // initEdbData 指标服务 数据表
  91. func initEdbData() {
  92. orm.RegisterModel(
  93. new(data_manage.SearchKeyword),
  94. )
  95. }