MySQL sender

[KristianLyng]

MySQL sender

[u5surf]

I try this issue now, it is key point how replace from pq.CopyIn

I think it can replace into LOAD DATA LOCAL INFILE...
e.g.

func CopyInMySQL(table string, columns ...string) string {
	stmt := "LOAD DATA LOCAL INFILE ‘/dev/stdin’ " + QuoteIdentifier(table) + " ("
	for i, col := range columns {
		if i != 0 {
			stmt += ", "
		}
		stmt += quoteIdentifier(col)
	}
	stmt += ") TERMINATED BY ‘\n’ ENCLOSED BY ‘\“‘ ESCAPED BY ‘\“‘"
	return stmt

func quoteIdentifier(name string) string {
	end := strings.IndexRune(name, 0)
	if end > -1 {
		name = name[:end]
	}
	return `"` + strings.Replace(name, `"`, `""`, -1) + `"`
}

https://dev.mysql.com/doc/refman/5.6/ja/load-data.html

[KristianLyng]

@u5surf I think you can get away with "INSERT INTO" within a transaction also. I did that with postgres in an earlier perl-based PoC and the performance was OK enough.

[KristianLyng]

I've added a MySQL sender now that will most likely be renamed and made to support multiple databases. It's worth noting that this new sender is NOT in direct contest with the one relevant to this issue. The one that now exists only handles specific schemas/metrics, which is an important use case, but entirely distinct from this issue that deals with arbitrary input data.

[KristianLyng]

Closing this as the actual sender works.