本教程操作环境:windows7系统、go 1.18版本、dell g3电脑。
golang支持多种数据库
1、mysql
mysql是一款关系型数据库管理系统,mysql采用了双授权政策,可以将数据保存在不同的表中,从而增加数据库的速度和灵活性,具有体积小、速度快、总体拥有成本低的特点。
2、oracle
oracle是一款关系数据库管理系统,在数据库领域处于领先地位,领先地位具有可移植性好、使用方便、功能强的特点,适用于各类大、中、小、微机环境,是一种效率高、可靠性好、吞吐量高的数据库。
3、sqlite
sqlite是一款轻型数据库,其遵循acid关系型数据库管理系统,其设计目的为嵌入式,所用可以在很多嵌入式产品中使用sqlite,同时可以和c#、php、java等程序语言相结合使用。
4、mongodb
mongodb是一个基于分布式文件存储的数据库,其目的是为web应用提供可扩展的高性能数据存储方案,mongodb支持的数据结构非常松散,且支持多查询语言和建立索引。
5、postgresql
postgresql是一个功能强大、源代码开放的对象关系型数据库管理系统,具有复杂查询、外键、触发器、视图、事务完整性、多版本并发控制等特性,postgresql可以通过函数在数据库服务器端执行指令程序,且用户可以自定义索引方法。
6、sql sever
sql sever是一个关系型数据库管理系统,具有使用方便、可伸缩性好、相关软件集成程度高的优点,可以提供更安全可靠的存储性能,使用sql sever可以构建和管理用于业务的高可用和高性能的数据应用程序。
golang操作mysql数据库
下面主要从增删查改以及事物等方面介绍go语言中mysql的使用
一、连接数据库
使用sql.open()函数打开数据库连接,数据库的连接字符串(dsn)格式如下:
admin:123456@tcp(10.2.1.5)/irisapp
代码如下:
func (f *mysql_db) mysql_open() { db, err := sql.open("mysql", dbusername+":"+dbpassword+"@tcp("+dbhostsip+")/"+dbname) if err != nil { fmt.println("链接失败") } fmt.println("链接成功") f.db = db}
二、插入
func (f *mysql_db) mysql_insert() { //insert 添加数据 fmt.println("开始插入") stmt, err := f.db.prepare("insert into depart(departname,memo) values(?,?)") //defer stmt.close() if err != nil { fmt.println("插入失败") return } stmt.exec("dd", "adadcccda") fmt.println("插入成功")}
三、查询
func (f *mysql_db) mysql_select(sql_data string) { //select 查询数据 fmt.println("sql:", sql_data) rows, err := f.db.query(sql_data) if err != nil { fmt.println("查询失败") } for rows.next() { var departid int var departname string var memo string err = rows.scan(&departid, &departname, &memo) if err != nil { panic(err) } fmt.println("departname:", departname) }}
四、更新
func (f *mysql_db) mysql_update() { //update 修改数据 stmt, err := f.db.prepare("update depart set departname=?,memo =? where departid=?") //defer stmt.close() if err != nil { //错误处理 } result,_ := stmt.exec("aa","asdfadsadsfa",1) if result == nil { fmt.println("修改失败") } affect_count,_ := result.rowsaffected() //返回影响的条数,注意有两个返回值 fmt.println("%v",affect_count)}
五、删除
func (f *mysql_db) mysql_delete() { //delete 删除数据 stmt, err := f.db.prepare("delete from depart where departid=?") //defer stmt.close() if err != nil { //错误处理 } stmt.exec(2) //不返回任何结果 fmt.println("删除成功")}
六、事物
func (f *mysql_db) mysql_tran(){ //事务 tx,err := f.db.begin() //声明一个事务的开始 if err != nil { fmt.println(err) return } insert_sql := "insert into depart (departname,memo) values(?,?)" insert_stmt,insert_err := tx.prepare(insert_sql) if insert_err != nil { fmt.println(insert_err) return } insert_res,insert_err := insert_stmt.exec("ff","ff") last_insert_id,_ := insert_res.lastinsertid() fmt.println(last_insert_id) // defer tx.rollback() //回滚之前上面的last_login_id是有的,但在回滚后该操作没有被提交,被回滚了,所以上面打印的last_login_id的这条数据是不存在与数据库表中的 tx.commit() //这里提交了上面的操作,所以上面的执行的sql 会在数据库中产生一条数据}
调用
func main() { db := &mysql_db{} db.mysql_open() db.mysql_insert() db.mysql_update() db.mysql_delete() db.mysql_tran() db.mysql_select("select departid,departname,memo from depart") db.mysql_close() //关闭}
启动后输出如下:
d:\go_path\go\src\mysqldemo>go run mysqldemo.go链接成功开始插入插入成功0删除成功10sql: select departid,departname,memo from departdepartname: aadepartname: dddepartname: dddepartname: dddepartname: dddepartname: dddepartname: ffdepartname: dddepartname: ff
完整代码
package mainimport ( "database/sql" "fmt" _ "github.com/go-sql-driver/mysql" )var ( dbhostsip = "10.2.1.5:3306" dbusername = "admin" dbpassword = "123456" dbname = "irisapp")type mysql_db struct { db *sql.db}func (f *mysql_db) mysql_open() { db, err := sql.open("mysql", dbusername+":"+dbpassword+"@tcp("+dbhostsip+")/"+dbname) if err != nil { fmt.println("链接失败") } fmt.println("链接成功") f.db = db}func (f *mysql_db) mysql_close() { defer f.db.close()}func (f *mysql_db) mysql_select(sql_data string) { //select 查询数据 fmt.println("sql:", sql_data) rows, err := f.db.query(sql_data) if err != nil { fmt.println("查询失败") } for rows.next() { var departid int var departname string var memo string err = rows.scan(&departid, &departname, &memo) if err != nil { panic(err) } fmt.println("departname:", departname) }}func (f *mysql_db) mysql_insert() { //insert 添加数据 fmt.println("开始插入") stmt, err := f.db.prepare("insert into depart(departname,memo) values(?,?)") //defer stmt.close() if err != nil { fmt.println("插入失败") return } stmt.exec("dd", "adadcccda") fmt.println("插入成功")}func (f *mysql_db) mysql_update() { //update 修改数据 stmt, err := f.db.prepare("update depart set departname=?,memo =? where departid=?") //defer stmt.close() if err != nil { //错误处理 } result,_ := stmt.exec("aa","asdfadsadsfa",1) if result == nil { fmt.println("修改失败") } affect_count,_ := result.rowsaffected() //返回影响的条数,注意有两个返回值 fmt.println(affect_count)}func (f *mysql_db) mysql_delete() { //delete 删除数据 stmt, err := f.db.prepare("delete from depart where departid=?") //defer stmt.close() if err != nil { //错误处理 } stmt.exec(2) //不返回任何结果 fmt.println("删除成功")}func (f *mysql_db) mysql_tran(){ //事务 tx,err := f.db.begin() //声明一个事务的开始 if err != nil { fmt.println(err) return } insert_sql := "insert into depart (departname,memo) values(?,?)" insert_stmt,insert_err := tx.prepare(insert_sql) if insert_err != nil { fmt.println(insert_err) return } insert_res,insert_err := insert_stmt.exec("ff","ff") last_insert_id,_ := insert_res.lastinsertid() fmt.println(last_insert_id) // defer tx.rollback() //回滚之前上面的last_login_id是有的,但在回滚后该操作没有被提交,被回滚了,所以上面打印的last_login_id的这条数据是不存在与数据库表中的 tx.commit() //这里提交了上面的操作,所以上面的执行的sql 会在数据库中产生一条数据}func main() { db := &mysql_db{} db.mysql_open() db.mysql_insert() db.mysql_update() db.mysql_delete() db.mysql_tran() db.mysql_select("select departid,departname,memo from depart") db.mysql_close() //关闭}
总结
1. 支持预备表达式,可以用来优化sql查询提高性能,减少sql注入的风险, db.prepare()和 tx.prepare 都提供了对于预备表达式的支持。
2. lastinsertid()获取插入第一条的id
3. rowsaffected()获取影响/插入的条数
4. 这里只是简单介绍了go语言开发中mysql在go语言开发中的基本使用,其实真正开发过程中还是主要使用orm相关第三方框架,但是底层原理还是要学的。
更多go语言知识请关注go语言教程栏目。
以上就是go语言搭载什么数据库的详细内容。