So I have golang program that reads a JSON off a kafka queue, makes it into normal flat syntax and pushes to a database table. The table is has (200+) columns, if the data doesn't contain a column, a null should be inserted.
Currently I can do that by forming the INSERT statement manually(with the present fields), problem comes with database arguments, how do I pass the argument to db.Query ?
The database to be populated is postgresql.
分享 Assuming column values will default to null if not set, here's one approach.
Create a map of column names to interface{} values:
args := make(map[string]interface{})
Set the column values you're interested in:
args["col_x"] = . . .
args["col_y"] = . . .
Prepare the sql statement:
sql = "insert into tab ( xxx ) values ( yyy )"
where xxx is the list of column names, and yyy is the list of value replacement characters, one for each value, specific to the database, eg, ?
Finally execute the query, expanding args as a variadic parameter:
db.Exec(sql, args...)
