首先直接上结果:
可以看到结果成功连接了数据库,并且得到了想要的结果。那么如何实现呢?
直接贴上代码:
package main import ( "fmt" _ "github.com/go-sql-driver/mysql" "database/sql" //"github.com/widuu/gojson" ) var ( dbhostsip = "主机" dbusername = "用户名称" dbpassowrd = "用户密码" dbname = "数据库名称" ) type mysql_db struct { db *sql.DB //定义结构体 } func (f *mysql_db) mysql_open() { //打开 Odb, err := sql.Open("mysql", dbusername+":"+dbpassowrd+"@tcp("+dbhostsip+")/"+dbname) if err != nil { fmt.Println("链接失败") } fmt.Println("链接数据库成功...........已经打开") f.db = Odb } func (f *mysql_db) mysql_close() { //关闭 defer f.db.Close() fmt.Println("链接数据库成功...........已经关闭") } func (f *mysql_db) mysql_select(sql_data string) { rows, err := f.db.Query(sql_data) if err != nil { println(err) } for rows.Next() { var djbh string fmt.Println(djbh) } } func main() { db := &mysql_db{} db.mysql_open() db.mysql_select("SELECT djbh FROM 表名") db.mysql_close() //关闭 }
然后直接 go run test.go,如果结果报错如下:cannot find package "github.com/go-sql-driver/mysql" in any of
执行下面两个命令:
下载:go get github.com/Go-SQL-Driver/MySQL
安装:go install github.com/Go-SQL-Driver/MySQL
然后,你就可以成功连接数据库,并且得到查询结果了。