matchSchema returns the predicate for matching table schema.
(columns ...string)
| 63 | |
| 64 | // matchSchema returns the predicate for matching table schema. |
| 65 | func (d *MySQL) matchSchema(columns ...string) *sql.Predicate { |
| 66 | column := "TABLE_SCHEMA" |
| 67 | if len(columns) > 0 { |
| 68 | column = columns[0] |
| 69 | } |
| 70 | if d.schema != "" { |
| 71 | return sql.EQ(column, d.schema) |
| 72 | } |
| 73 | return sql.EQ(column, sql.Raw("(SELECT DATABASE())")) |
| 74 | } |
| 75 | |
| 76 | func (d *MySQL) atOpen(conn dialect.ExecQuerier) (migrate.Driver, error) { |
| 77 | return mysql.Open(&db{ExecQuerier: conn}) |
no test coverage detected