CreateDB initialize the db object
( dbKind sqlplugin.DbKind, cfg *config.SQL, r resolver.ServiceResolver, logger log.Logger, _ metrics.Handler, )
| 55 | |
| 56 | // CreateDB initialize the db object |
| 57 | func (p *plugin) CreateDB( |
| 58 | dbKind sqlplugin.DbKind, |
| 59 | cfg *config.SQL, |
| 60 | r resolver.ServiceResolver, |
| 61 | logger log.Logger, |
| 62 | _ metrics.Handler, |
| 63 | ) (sqlplugin.GenericDB, error) { |
| 64 | conn, err := p.connPool.Allocate(cfg, r, logger, p.createDBConnection) |
| 65 | if err != nil { |
| 66 | return nil, err |
| 67 | } |
| 68 | db := newDB(dbKind, cfg.DatabaseName, conn, nil, logger) |
| 69 | db.OnClose(func() { p.connPool.Close(cfg) }) // remove reference |
| 70 | return db, nil |
| 71 | } |
| 72 | |
| 73 | // createDBConnection creates a returns a reference to a logical connection to the |
| 74 | // underlying SQL database. The returned object is tied to a single |