Method deleteByPK

plugins/destination/duckdb/client/write.go:106–119

(ctx context.Context, tmpTableName string, table *schema.Table)

}

func (c *Client) deleteByPK(ctx context.Context, tmpTableName string, table *schema.Table) error {
	var sb strings.Builder
	sb.WriteString("delete from " + table.Name + " using " + tmpTableName + " where ")
	for i, col := range table.PrimaryKeys() {
		if i > 0 {
			sb.WriteString(" and ")
		}
		sb.WriteString(table.Name + "." + sanitizeID(col))
		sb.WriteString(" = ")
		sb.WriteString(tmpTableName + "." + sanitizeID(col))
	}

	return c.exec(ctx, sb.String())
}

func (c *Client) copyFromFile(ctx context.Context, tableName string, fileName string, table *schema.Table) error {
	return c.exec(ctx, "copy "+tableName+