package main
import (
"fmt"
"database/sql"
_ "github.com/go-sql-driver/mysql"
)
type TestMysql struct {
db * sql.DB
}
func Init()(*TestMysql?? error) {
test := new (TestMysql)
db?? err := sql.Open("mysql"??"root:@tcp(172.16.3.8:3306)/jackma?charset=utf8")
if err != nil {
fmt.Println(err.Error())
return test??nil
}
test.db = db
return test?? nil
}
func (test* TestMysql)Create(){
if test.db == nil {
return
}
stmt ?? err := test.db.Prepare("insert into test(name?? id) values (??? ?)")
if err != nil {
fmt.Println(err.Error())
return
}
defer stmt.Close()
if result?? err := stmt.Exec("jack"??20); err == nil {
if id?? err := result.LastInsertId(); err == nil {
fmt.Println("insert id :"??id)
}
}
if result?? err := stmt.Exec("jack2"??30); err == nil {
if id?? err := result.LastInsertId(); err == nil {
fmt.Println("insert id :"??id)
}
}
if result?? err := stmt.Exec("jack3"??40); err == nil {
if id?? err := result.LastInsertId(); err == nil {
fmt.Println("insert id :"??id)
}
}
if result?? err := stmt.Exec("jack4"??60); err == nil {
if id?? err := result.LastInsertId(); err == nil {
fmt.Println("insert id :"??id)
}
}
}
func (test *TestMysql)Update(){
if(test.db == nil){
return
}
stmt?? err := test.db.Prepare("update test set name =? where id = ?")
if err != nil {
fmt.Println(err.Error())
return
}
defer stmt.Close()
if result?? err := stmt.Exec("jackma4888"??60); err == nil {
if c?? err := result.RowsAffected(); err == nil {
fmt.Println("update count:"??c)
}
}
}
func (test* TestMysql)Read(){
if test.db == nil{
return
}
rows ?? err := test.db.Query("select id?? name from test")
if err != nil {
fmt.Println(err.Error())
return
}
defer rows.Close()
fmt.Println("")
clos?? _ := rows.Columns()
for i := range clos {
fmt.Print(clos[i])
fmt.Print(" ")
}
fmt.Println("")
var id int;
var name string;
for rows.Next() {
if err := rows.Scan(&id?? &name); err != nil {
fmt.Print(id)
fmt.Print(" ")
fmt.Print(name)
fmt.Print(" ")
fmt.Print(" ")
}
}
}
func (test *TestMysql) Delete(){
if test.db == nil{
return
}
stmt ?? err := test.db.Prepare("delete from test where id = ?")
if err != nil {
fmt.Println(err.Error())
return
}
defer stmt.Close()
if result?? err := stmt.Exec(20); err == nil {
if c?? err := result.RowsAffected(); err == nil {
fmt.Println("delete count :"??c)
}
}
}
func (test *TestMysql)Close(){
if test.db != nil {
test.db.Close()
}
}
func main(){
if test?? err := Init(); err == nil {
fmt.Println("create:")
test.Create()
fmt.Println("update:")
test.Update()
fmt.Println("read:")
test.Read()
fmt.Println("delete:")
test.Delete()
test.Read()
fmt.Println("close:")
test.Close()
}
}