()
| 101 | return nil, schema.ErrNotFound |
| 102 | } |
| 103 | func (m *JsonSource) loadTable() error { |
| 104 | tbl := schema.NewTable(strings.ToLower(m.table)) |
| 105 | columns := m.Columns() |
| 106 | for i := range columns { |
| 107 | columns[i] = strings.ToLower(columns[i]) |
| 108 | tbl.AddField(schema.NewFieldBase(columns[i], value.StringType, 64, "string")) |
| 109 | } |
| 110 | tbl.SetColumns(columns) |
| 111 | m.tbl = tbl |
| 112 | return nil |
| 113 | } |
| 114 | func (m *JsonSource) Open(connInfo string) (schema.Conn, error) { |
| 115 | if connInfo == "stdio" || connInfo == "stdin" { |
| 116 | connInfo = "/dev/stdin" |
nothing calls this directly
no test coverage detected