Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- func CreateAtcfs(host, port, db_name, username, password, compress, debug string, data []AtcfsItem) {
- connect, err := sql.Open("clickhouse", "tcp://"+host+":"+port+"?database="+db_name+"&username="+username+"&password="+password+"&compress="+compress+"&debug="+debug+"\"")
- checkErr(err)
- if err := connect.Ping(); err != nil {
- if exception, ok := err.(*clickhouse.Exception); ok {
- log.Printf("[%d] %s \n%s\n", exception.Code, exception.Message, exception.StackTrace)
- } else {
- log.Println(err)
- }
- return
- }
- _, err = connect.Exec(`
- CREATE TABLE IF NOT EXISTS atcfs (
- uniqueid String,
- atcfsid String,
- eventDate Date
- ) engine=MergeTree(eventDate, (eventDate), 8192)
- `)
- checkErr(err)
- tx, err := connect.Begin()
- checkErr(err)
- stmt, err := tx.Prepare("INSERT INTO atcfs (uniqueid, atcfsid, eventDate) VALUES (?,?,?)")
- checkErr(err)
- defer stmt.Close()
- for _, value := range data {
- if _, err := stmt.Exec(
- value.Uniqueid,
- value.Atcfsid,
- value.EventDate,
- ); err != nil {
- log.Println(err)
- }
- }
- checkErr(tx.Commit())
- defer connect.Close()
- return
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement