()
| 67 | return nil, schema.ErrNotFound |
| 68 | } |
| 69 | func (m *storeSource) loadTable() error { |
| 70 | m.mu.Lock() |
| 71 | defer m.mu.Unlock() |
| 72 | if m.tbl != nil { |
| 73 | return nil |
| 74 | } |
| 75 | // u.Debugf("storeSource.loadTable(%q)", m.table) |
| 76 | tbl := schema.NewTable(strings.ToLower(m.table)) |
| 77 | columns := m.Columns() |
| 78 | for i := range columns { |
| 79 | columns[i] = strings.ToLower(columns[i]) |
| 80 | tbl.AddField(schema.NewFieldBase(columns[i], value.StringType, 64, "string")) |
| 81 | } |
| 82 | tbl.SetColumns(columns) |
| 83 | m.tbl = tbl |
| 84 | return nil |
| 85 | } |
| 86 | func (m *storeSource) Open(connInfo string) (schema.Conn, error) { |
| 87 | |
| 88 | // u.Debugf("Open(%q)", connInfo) |
no test coverage detected