(dbID string)
| 116 | } |
| 117 | |
| 118 | func (s *CovenantSQLStorage) getConn(dbID string) (db *sql.DB, err error) { |
| 119 | cfg := client.NewConfig() |
| 120 | cfg.DatabaseID = dbID |
| 121 | if s.mirrorServerAddr != "" { |
| 122 | cfg.Mirror = s.mirrorServerAddr |
| 123 | } |
| 124 | |
| 125 | return sql.Open("covenantsql", cfg.FormatDSN()) |
| 126 | } |