package main import ( "database/sql" "log" _ "xugu_driver/xugu" ) func main() { db, err := sql.Open("xugusql", "IP=10.28.20.101;DB=SYSTEM;User=SYSDBA;PWD=SYSDBA;Port=5190;AUTO_COMMIT=on;CHAR_SET=UTF8") //_, err = db.Exec("create table go_test(c1 int, c2 varchar);") db.Ping() if err != nil { log.Fatal(err) } // row, err := db.Query("select * from gotest2;") // if err != nil { // fmt.Println("查询错误", err) // } // fmt.Println("row", row) // col, _ := row.Columns() // fmt.Println("row.Columns(): ", col) // type1, _ := row.ColumnTypes() // fmt.Printf("type:%#v \n ", type1) // pvals := make([]interface{}, len(col)) // for row.Next() { // fmt.Println("row.Next():main ") // row.Scan(pvals) // for _, v := range pvals { // fmt.Printf("pvals:%v\t \n", v) // fmt.Printf("pvals:%v\t \n", (v.(*[]byte))) // } // fmt.Printf("\n") // break // } //消息类型为E //db.Exec("drop table ta3;") db.Exec("INSERT INTO gotest VALUES('gc');") db.Close() }