How to do it…

  1. Install the github.com/go-sql-driver/mysql package, using the go get command, as follows:
$ go get github.com/go-sql-driver/mysql
  1. Create connect-mysql.go. Then we connect to the MySQL database and perform a SELECT query to get the current database name, as follows:
package main
import
(
"database/sql"
"fmt"
"log"
"net/http"
"github.com/go-sql-driver/mysql"
)
const
(
CONN_HOST = "localhost"
CONN_PORT = "8080"
DRIVER_NAME = "mysql"
DATA_SOURCE_NAME = "root:password@/mydb"
)
var db *sql.DB
var connectionError error
func init()
{
db, connectionError = sql.Open(DRIVER_NAME, DATA_SOURCE_NAME)
if connectionError != nil
{
log.Fatal("error connecting to database :: ", connectionError)
}
}
func getCurrentDb(w http.ResponseWriter, r *http.Request)
{
rows, err := db.Query("SELECT DATABASE() as db")
if err != nil
{
log.Print("error executing query :: ", err)
return
}
var db string
for rows.Next()
{
rows.Scan(&db)
}
fmt.Fprintf(w, "Current Database is :: %s", db)
}
func main()
{
http.HandleFunc("/", getCurrentDb)
defer db.Close()
err := http.ListenAndServe(CONN_HOST+":"+CONN_PORT, nil)
if err != nil
{
log.Fatal("error starting http server :: ", err)
return
}
}
  1. Run the program with the following command: 
$ go run connect-mysql.go
..................Content has been hidden....................

You can't read the all page of ebook, please click here login for view all page.
Reset
18.117.187.113