(b *testing.B, compress bool, queries ...string)
| 47 | } |
| 48 | |
| 49 | func initDB(b *testing.B, compress bool, queries ...string) *sql.DB { |
| 50 | tb := (*TB)(b) |
| 51 | comprStr := "" |
| 52 | if compress { |
| 53 | comprStr = "&compress=1" |
| 54 | } |
| 55 | db := tb.checkDB(sql.Open(driverNameTest, dsn+comprStr)) |
| 56 | for _, query := range queries { |
| 57 | if _, err := db.Exec(query); err != nil { |
| 58 | b.Fatalf("error on %q: %v", query, err) |
| 59 | } |
| 60 | } |
| 61 | return db |
| 62 | } |
| 63 | |
| 64 | const concurrencyLevel = 10 |
| 65 |
no test coverage detected