(rawDB *sql.DB, dsn string)
| 101 | } |
| 102 | |
| 103 | func NewDB(rawDB *sql.DB, dsn string) *DB { |
| 104 | var db = &DB{ |
| 105 | rawDB: rawDB, |
| 106 | dsn: dsn, |
| 107 | } |
| 108 | |
| 109 | events.OnKey(events.EventQuit, fmt.Sprintf("db_%p", db), func() { |
| 110 | _ = db.Close() |
| 111 | }) |
| 112 | events.OnKey(events.EventTerminated, fmt.Sprintf("db_%p", db), func() { |
| 113 | _ = db.Close() |
| 114 | }) |
| 115 | |
| 116 | return db |
| 117 | } |
| 118 | |
| 119 | func (this *DB) SetMaxOpenConns(n int) { |
| 120 | this.rawDB.SetMaxOpenConns(n) |