Method WriteTableBatch

plugins/destination/mssql/client/write.go:18–36

(ctx context.Context, _ string, messages message.WriteInserts)

}

func (c *Client) WriteTableBatch(ctx context.Context, _ string, messages message.WriteInserts) error {
	if len(messages) == 0 {
		return nil
	}

	table := messages[0].GetTable()
	records := make([]arrow.RecordBatch, len(messages))
	for i, m := range messages {
		records[i] = m.Record
	}

	if useTVP(table) {
		return c.insertTVP(ctx, table, records)
	}

	return c.doInTx(ctx, func(tx *sql.Tx) error {
		return c.bulkInsert(ctx, tx, table, records)
	})
}