initDb.go 4.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167
  1. package global
  2. import (
  3. "database/sql/driver"
  4. _ "dm"
  5. dm "dmgorm2"
  6. "eta/eta_chart_lib/utils"
  7. "fmt"
  8. "gorm.io/driver/mysql"
  9. "gorm.io/gorm"
  10. "gorm.io/gorm/logger"
  11. "gorm.io/gorm/schema"
  12. "io"
  13. "log"
  14. "os"
  15. "strings"
  16. "time"
  17. )
  18. var (
  19. //需要钩子函数执行的数据库表
  20. tableMap = map[string]int{
  21. "base_from_mysteel_chemical_data": 1,
  22. "future_good_edb_info": 1,
  23. }
  24. )
  25. type LocalTime time.Time
  26. // InitDb
  27. // @Description: 数据库初始化
  28. func InitDb() {
  29. dbMap := make(map[string]*gorm.DB)
  30. //开启日志
  31. logWriter := io.MultiWriter(utils.Binlog) //binlog日志,记录到文件中去
  32. if utils.RunMode == `dev` { // 测试环境,默认输出在控制台,不需要的话,可以注释if里面下面的这行
  33. logWriter = io.MultiWriter(utils.Binlog, os.Stdout)
  34. }
  35. newLogger := logger.New(log.New(logWriter, "\r\n", log.LstdFlags), logger.Config{
  36. SlowThreshold: 200 * time.Millisecond, //慢sql :200ms
  37. LogLevel: logger.Info, //记录的日志类型,info代表所有信息都记录
  38. IgnoreRecordNotFoundError: true, //是否忽略找不到数据错误信息(只是日志记录记录成err还是普通的输出的区别,并不影响业务代码中的:找不到数据行error)
  39. Colorful: false, //是否颜色输出
  40. })
  41. // 默认库
  42. connectDb(utils.MYSQL_URL, utils.DbNameMaster, newLogger, dbMap, true)
  43. // 手工数据库
  44. connectDb(utils.MYSQL_URL_EDB, utils.DbNameManualIndex, newLogger, dbMap, false)
  45. // 指标库
  46. connectDb(utils.MYSQL_URL_DATA, utils.DbNameIndex, newLogger, dbMap, false)
  47. // gorm前置处理
  48. for _, db := range dbMap {
  49. _ = db.Callback().Query().Before("gorm:query").Register("before_query", func(tx *gorm.DB) {
  50. orgSql := tx.Statement.SQL.String()
  51. if _, ok := tableMap[tx.Statement.Table]; ok && strings.Contains(strings.ToLower(orgSql), "select") {
  52. newSql := utils.ReplaceDriverKeywords(utils.DbDriverName, orgSql)
  53. tx.Statement.SQL.Reset()
  54. tx.Statement.SQL.WriteString(newSql)
  55. }
  56. })
  57. _ = db.Callback().Raw().Before("gorm:raw").Register("before_raw", func(tx *gorm.DB) {
  58. orgSql := tx.Statement.SQL.String()
  59. if _, ok := tableMap[tx.Statement.Table]; ok &&
  60. (strings.Contains(strings.ToLower(orgSql), "delete") ||
  61. strings.Contains(strings.ToLower(orgSql), "update") ||
  62. strings.Contains(strings.ToLower(orgSql), "insert")) {
  63. newSql := utils.ReplaceDriverKeywords(utils.DbDriverName, orgSql)
  64. tx.Statement.SQL.Reset()
  65. tx.Statement.SQL.WriteString(newSql)
  66. }
  67. })
  68. }
  69. //全局赋值数据库链接
  70. DbMap = dbMap
  71. }
  72. // connectDb
  73. // @Description: 达梦数据库连接
  74. // @param dsn
  75. // @param aliasName
  76. // @param newLogger
  77. // @param dbMap
  78. // @param isDefault
  79. func connectDb(dsn, aliasName string, newLogger logger.Interface, dbMap map[string]*gorm.DB, isDefault bool) {
  80. //fmt.Println("dsn:", dsn, " == ;aliasName:", aliasName)
  81. if dsn == `` {
  82. return
  83. }
  84. var dialector gorm.Dialector
  85. switch utils.DbDriverName {
  86. case utils.DbDriverByMysql:
  87. if !strings.Contains(dsn, `parseTime`) {
  88. dsn += `&parseTime=true`
  89. }
  90. dialector = mysql.Open(dsn)
  91. case utils.DbDriverByDm:
  92. dialector = dm.Open(dsn)
  93. default:
  94. panic(fmt.Errorf("数据库 链接异常,错误的数据库类型,数据库:%s", utils.DbDriverName))
  95. }
  96. db, err := gorm.Open(dialector, &gorm.Config{
  97. Logger: newLogger,
  98. NamingStrategy: schema.NamingStrategy{
  99. SingularTable: true, // 表示使用单数表名,启用该选项后,GORM 将不会对表名进行复数化处理
  100. },
  101. })
  102. if err != nil {
  103. //global.LOG.Errorf("mysql 启动异常,数据库:default;Err:", err)
  104. panic(fmt.Errorf("数据库 链接异常,数据库:%s;Err:%s", aliasName, err))
  105. }
  106. //创建连接池
  107. sqlDB, err := db.DB()
  108. if err != nil {
  109. //global.LOG.Errorf("达梦 创建连接池失败,数据库:default;Err:", err)
  110. panic(fmt.Errorf("数据库 创建连接池失败,数据库:%s;Err:%s", aliasName, err))
  111. }
  112. dbMap[aliasName] = db
  113. //默认数据库连接
  114. if isDefault {
  115. DEFAULT_DB = db
  116. }
  117. // SetMaxIdleConns 设置空闲连接池中连接的最大数量
  118. sqlDB.SetMaxIdleConns(50)
  119. // SetMaxOpenConns 设置打开数据库连接的最大数量。
  120. sqlDB.SetMaxOpenConns(100)
  121. // SetConnMaxLifetime 设置了连接可复用的最大时间。
  122. sqlDB.SetConnMaxLifetime(10 * time.Minute)
  123. }
  124. func (t *LocalTime) MarshalJSON() ([]byte, error) {
  125. tTime := time.Time(*t)
  126. if tTime.IsZero() {
  127. return []byte("\"\""), nil
  128. }
  129. return []byte(fmt.Sprintf("\"%v\"", tTime.Format("2006-01-02 15:04:05"))), nil
  130. }
  131. func (t LocalTime) Value() (driver.Value, error) {
  132. var zeroTime time.Time
  133. tlt := time.Time(t)
  134. //判断给定时间是否和默认零时间的时间戳相同
  135. if tlt.UnixNano() == zeroTime.UnixNano() {
  136. return nil, nil
  137. }
  138. return tlt, nil
  139. }
  140. func (t *LocalTime) Scan(v interface{}) error {
  141. if value, ok := v.(time.Time); ok {
  142. *t = LocalTime(value)
  143. return nil
  144. }
  145. return fmt.Errorf("can not convert %v to timestamp", v)
  146. }