Golang连接MySQL数据库并进行简单查询

1、安装驱动

go get github.com/go-sql-driver/mysql

2、导入需要的库
import ( "database/sql" "fmt" _ "github.com/go-sql-driver/mysql" )

3、连接数据库
func main() { //"用户名:密码@[连接方式](主机名:端口号)/数据库名" db, _ := sql.Open("mysql", "root:123456@(localhost)/world") // 设置连接数据库的参数 defer db.Close()//关闭数据库 err := db.Ping()//连接数据库 if err != nil { fmt.Println("数据库连接失败")//连接失败 return } else { fmt.Println("数据库连接成功")//连接成功 } }

4、查询表
rows, _ := db.Query("select * from city") //获取city表所有数据 var ID, Population int var Name, CountryCode, District string for rows.Next() { //循环显示所有的数据 rows.Scan(&ID, &Name, &CountryCode, &District, &Population) fmt.Println(ID, "--", Name, "--", CountryCode, "--", District, "--", Population) }

【Golang连接MySQL数据库并进行简单查询】查询截图:
Golang连接MySQL数据库并进行简单查询
文章图片

5、全部代码
package mainimport ( "database/sql" "fmt" _ "github.com/go-sql-driver/mysql" )func main() { //"用户名:密码@[连接方式](主机名:端口号)/数据库名" db, _ := sql.Open("mysql", "root:123456@(localhost)/world") // 设置连接数据库的参数 defer db.Close()//关闭数据库 err := db.Ping()//连接数据库 if err != nil { fmt.Println("数据库连接失败") return } else { fmt.Println("数据库连接成功") }//多行查询 rows, _ := db.Query("select * from city") //获取所有数据 var ID, Population int var Name, CountryCode, District string for rows.Next() { //循环显示所有的数据 rows.Scan(&ID, &Name, &CountryCode, &District, &Population) fmt.Println(ID, "--", Name, "--", CountryCode, "--", District, "--", Population) } }

6、拓展
//操作一:执行数据操作语句sql:="insert into stu values (2,'berry')" result,_:=db.Exec(sql)//执行SQL语句 n,_:=result.RowsAffected(); //获取受影响的记录数 fmt.Println("受影响的记录数是",n)//操作二:执行预处理stu:=[2][2] string{{"3","ketty"},{"4","rose"}} stmt,_:=db.Prepare("insert into stu values (?,?)")//获取预处理语句对象 for _,s:=range stu{ stmt.Exec(s[0],s[1])//调用预处理语句 }//操作三:单行查询var id,name string rows:=db.QueryRow("select * from stu where id=4")//获取一行数据 rows.Scan(&id,&name)//将rows中的数据存到id,name中 fmt.Println(id,"--",name)

    推荐阅读