Function ingestDataForTable

examples/examples.go:187–215

(connector client.Connector, tableName string, dataPath string)

}

func ingestDataForTable(connector client.Connector, tableName string, dataPath string) {
	file, err := os.Open(dataPath)
	panicIfErr(err)
	defer file.Close()

	csvReader := csv.NewReader(file)
	columnNames, err := csvReader.Read()
	panicIfErr(err)

	rows := make([]client.Row, 0)
	var record []string

	for record, err = csvReader.Read(); err != io.EOF; record, err = csvReader.Read() {
		panicIfErr(err)
		row := make(client.Row, 0, len(record))
		for _, value := range record {
			if strings.HasPrefix(value, "{") && strings.HasSuffix(value, "}") {
				row = append(row, parseAndGenerateRandomTime(value))
			} else {
				row = append(row, value)
			}
		}
		rows = append(rows, row)
	}
	rowsInserted, err := connector.Insert(tableName, columnNames, rows)
	panicIfErr(err)

	fmt.Printf("%d rows inserted into %s\n", rowsInserted, tableName)
}

func main() {
	rootCmd := &cobra.Command{