(ctx context.Context, tableName string, fileName string, table *schema.Table)
| 119 | } |
| 120 | |
| 121 | func (c *Client) copyFromFile(ctx context.Context, tableName string, fileName string, table *schema.Table) error { |
| 122 | return c.exec(ctx, "copy "+tableName+ |
| 123 | "("+strings.Join(sanitized(table.Columns.Names()), ", ")+ |
| 124 | ") from '"+fileName+"' (FORMAT PARQUET)") |
| 125 | } |
| 126 | |
| 127 | func (c *Client) Write(ctx context.Context, msgs <-chan message.WriteMessage) error { |
| 128 | if err := c.writer.Write(ctx, msgs); err != nil { |
no test coverage detected