package main

import (
	"fmt"
	"time"

	"github.com/GoogleCloudPlatform/cloudsql-proxy/proxy/dialers/mysql"
	"github.com/google/uuid"
)

const instanceConnectionName = "sinmetal-tokyo:asia-northeast1:sql1"
const databaseUser = "root"
const databaseName = "db1"
const password = "password"

func main() {
	for {
		insert()
	}
}

func insert() {
	cfg := mysql.Cfg(instanceConnectionName, databaseUser, password)
	cfg.DBName = databaseName
	db, err := mysql.DialCfg(cfg)
	if err != nil {
		panic(err.Error())
	}
	defer db.Close()

	stmtIns, err := db.Prepare("INSERT INTO sample (uuid, client_time, db_time) VALUES (?, ?, now())")
	if err != nil {
		panic(err.Error())
	}
	defer stmtIns.Close()

	id := uuid.New().String()
	result, err := stmtIns.Exec(id, time.Now())
	if err != nil {
		panic(err.Error())
	}

	insertId, err := result.LastInsertId()
	if err != nil {
		panic(err.Error())
	}
	affected, err := result.RowsAffected()
	if err != nil {
		panic(err.Error())
	}
	fmt.Printf("{\"LastInsertId\":\"%d\", \"RowsAffected\":%d}\n", insertId, affected)
}