MCPcopy Create free account
hub / github.com/Shopify/ghostferry / ScanByteRow

Function ScanByteRow

cursor.go:295–305  ·  view source on GitHub ↗
(rows *sqlorig.Rows, columnCount int)

Source from the content-addressed store, hash-verified

293}
294
295func ScanByteRow(rows *sqlorig.Rows, columnCount int) ([][]byte, error) {
296 values := make([][]byte, columnCount)
297 valuePtrs := make(RowData, columnCount)
298
299 for i, _ := range values {
300 valuePtrs[i] = &values[i]
301 }
302
303 err := rows.Scan(valuePtrs...)
304 return values, err
305}
306
307func DefaultBuildSelect(columns []string, table *TableSchema, lastPaginationKey PaginationKey, batchSize uint64) squirrel.SelectBuilder {
308 quotedPaginationKey := QuoteField(table.GetPaginationColumn().Name)

Callers 2

GetCompressedHashesMethod · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected