(mysql_uri string)
| 136 | } |
| 137 | |
| 138 | func CreateDB(mysql_uri string) (*gosql.DB, error) { |
| 139 | db, err := gosql.Open("mysql", mysql_uri) |
| 140 | if err != nil { |
| 141 | return nil, err |
| 142 | } |
| 143 | db.SetConnMaxLifetime(WaitTimeout * time.Second) |
| 144 | |
| 145 | return db, nil |
| 146 | } |
| 147 | |
| 148 | func CreateConns(ctx context.Context, db *gosql.DB, count int) ([]*Conn, error) { |
| 149 | conns := make([]*Conn, count) |
no outgoing calls
no test coverage detected