(connInfo string)
| 119 | return nil |
| 120 | } |
| 121 | func (m *CsvDataSource) Open(connInfo string) (schema.Conn, error) { |
| 122 | if connInfo == "stdio" || connInfo == "stdin" { |
| 123 | connInfo = "/dev/stdin" |
| 124 | } |
| 125 | f, err := os.Open(connInfo) |
| 126 | if err != nil { |
| 127 | return nil, err |
| 128 | } |
| 129 | exit := make(<-chan bool, 1) |
| 130 | return NewCsvSource(connInfo, 0, f, exit) |
| 131 | } |
| 132 | |
| 133 | func (m *CsvDataSource) Close() error { |
| 134 | defer func() { |
nothing calls this directly
no test coverage detected