cc_test/db.go

package main

import (
	"database/sql"
	"fmt"

	_ "github.com/go-sql-driver/mysql"
)

var db *sql.DB

func init() {
	var err error
	dbConfig := fmt.Sprintf("%s:%s@(%s:%s)/%s", DB_USER, DB_PASS, DB_HOST, DB_PORT, DB_DATABASE)
	db, err = sql.Open("mysql", dbConfig)
	if err != nil {
		fmt.Println(err)
	}
	db.SetMaxOpenConns(100)
	err = db.Ping()
	if err != nil {
		fmt.Println(err)
	}
}

func db_query(sql string, params ...interface{}) (*sql.Rows, error) {
	rows, err := db.Query(sql, params...)
	if err != nil {
		fmt.Println(err)
		return rows, err
	}
	return rows, nil
}

func db_exec(sql string, params ...interface{}) (sql.Result, error) {
	return db.Exec(sql, params...)
}