Method upsert

plugins/destination/sqlite/client/write.go:106–134

(sc *arrow.Schema)

}

func (*Client) upsert(sc *arrow.Schema) string {
	var sb strings.Builder
	tableName, ok := sc.Metadata().GetValue(schema.MetadataTableName)
	if !ok {
		panic("missing table name in schema metadata")
	}
	sb.WriteString("insert or replace into ")
	sb.WriteString(identifier(tableName))
	sb.WriteString(" (")
	columns := sc.Fields()
	columnsLen := len(columns)
	for i, c := range columns {
		sb.WriteString(identifier(c.Name))
		if i < columnsLen-1 {
			sb.WriteString(",")
		} else {
			sb.WriteString(") values (")
		}
	}
	for i := range columns {
		sb.WriteString(fmt.Sprintf("$%d", i+1))
		if i < columnsLen-1 {
			sb.WriteString(",")
		} else {
			sb.WriteString(")")
		}
	}
	return sb.String()
}