苏州建设建设信息网站,昆明网站开发报价,wordpress ssl,wordpress全能播放器代码Go语言操作数据库
Go语言提供了关于数据库的操作,包下有sql/driver 该包用来定义操作数据库的接口#xff0c;这保证了无论使用哪种数据库#xff0c;操作方式都是相同的; 准备工作:
下载驱动
需要在代码所在文件夹下执行相应的命令
go get github.com/go-sql-driver/mys…Go语言操作数据库
Go语言提供了关于数据库的操作,包下有sql/driver 该包用来定义操作数据库的接口这保证了无论使用哪种数据库操作方式都是相同的; 准备工作:
下载驱动
需要在代码所在文件夹下执行相应的命令
go get github.com/go-sql-driver/mysql
PS D:\GolandData go get github.com/go-sql-driver/mysql
go: downloading github.com/go-sql-driver/mysql v1.7.1
go: added github.com/go-sql-driver/mysql v1.7.1
安装驱动
go install github.com/go-sql-driver/mysql
安装之后检查go.mod文件 Go提供了sql包,但是没有指定是哪一个数据库的,用于访问特定数据库的方法交给了数据库驱动实现;
匿名导入包 匿名导入包——只导入包但是不使用包内的类型和数据使用匿名的方式在包路径前添加下画线“_”导入MySQL驱动。 为什么需要匿名导包—开发者不应该直接使用导入的驱动包所提供的方法,而应该使用sql.DB对象所提供的统一方法; 在导入一个数据库驱动后该驱动会自行初始化并注册到Golang的database/sql上下文中 连接数据库
连接数据库基础API
Driver接口中有一个方法Open()
/*数据库驱动程序可以实现DriverContext访问在一个连接池中只解析一次名称而不是每个连接一次。*/
type Driver interface {/* Open返回到数据库的新连接。该名称是驱动程序特定格式的字符串。 Open可能返回一个缓存的连接(先前的一个关闭的)但这样做是不必要的;SQL包维护一个空闲连接池以便有效地重用。返回的连接一次只被一个线程使用。*/Open(name string) (Conn, error)
}
sql包中有一个open(driverName, dataSourceName string)方法 该方法打开一个数据库连接,
func Open(driverName, dataSourceName string) (*DB, error) {driversMu.RLock()//这里说明一个线程用一个连接driveri, ok : drivers[driverName]driversMu.RUnlock()if !ok {return nil, fmt.Errorf(sql: unknown driver %q (forgotten import?), driverName)}if driverCtx, ok : driveri.(driver.DriverContext); ok {connector, err : driverCtx.OpenConnector(dataSourceName)if err ! nil {return nil, err}return OpenDB(connector), nil}return OpenDB(dsnConnector{dsn: dataSourceName, driver: driveri}), nil
}
参数释义----即连接数据库三要素
driverName–数据库驱动名dataSourceName数据库连接信息,数据库地址,用户名.密码, 数据库名等信息
由open()源代码可以看到,sql.Open()返回的sql.DB对象是并发安全的,即每次只能一个Goroutine使用一个,所以高并发下如果没有及时关闭不需要的连接,就会导致系统资源耗尽;
sql.DB的设计初衷是为长连接设计的,不宜频繁开关;
比较好的做法是为每个不同的datastore建一个DB对象保持这些对象打开。 如果需要短连接一次连接一次数据交互就把DB作为参数传入function而不要在function中开关。
CURD操作
来一段代码Demo
数据库查询
type BookInfo struct {BookId, BookName, BookPublish, BookKind stringBookPrice float64BookCount int
}func (b *BookInfo) DatabaseMysql() {//db, err : sql.Open(mysql, root:123456tcp(127.0.0.1:3306)/gavin?charsetutf8) //返回*DB, errordb, err : sql.Open(mysql, root:123456tcp(172.21.114.22:3306)/gavin?charsetutf8) //返回*DB, errorif err ! nil {fmt.Println(打开失败)fmt.Println(err.Error())return}fmt.Println(打开成功)fmt.Printf(%T\n, db)queryStr : select * from bookstore ; //sql语句//Exec执行一个不返回任何行的查询。//args用于查询中的任何占位参数。 看样子不能用这个方法//exec, err : db.Exec(queryStr) //返回Result ,err//fmt.Printf(类型%T \n 值 %v, exec, exec) // nil,nil//构建一个DB对象queryResult, err : db.Query(queryStr) //返回 *Rows, errorif err ! nil {fmt.Println(err.Error())return}for queryResult.Next() {queryResult.Scan(b.BookId, b.BookName, b.BookPublish, b.BookPrice, b.BookKind, b.BookCount)fmt.Printf(bookInfo信息: bookid: %s\t bookname: %s \t bookpublish: %s \t bookprice: %f \t bookkind: %s bookcount %d \n, b.BookId, b.BookName, b.BookPublish, b.BookPrice, b.BookKind, b.BookCount)}db.Close()}func main() {b : BookInfo{}b.DatabaseMysql()
}
获得的结果: 我们可以看到代码的基本思路跟java一样,go是定义一个结构体用于接收数据库中的数据,然后我们需要掌握下面的几个函数用于处理数据库数据;最后关闭数据库连接
使用db.Query()来发送查询到数据库获取结果集Rows并检查错误。使用rows.Next()作为循环条件迭代读取结果集。使用rows.Scan从结果集中获取一行结果。使用rows.Err()在退出迭代后检查错误。使用rows.Close()关闭结果集释放连接。 rows.Scan()方法的参数顺序很重要必须和查询结果的column相对应数量和顺序都需要一致 插入数据
// 插入
func (b *BookInfo) insertData() {//连接数据库db, err : sql.Open(mysql, root:123456tcp(172.21.114.22:3306)/gavin?charsetutf8)chkERR(err)insertStr : insert into bookstore VALUES(1024,Go并发实践,泉城出版社, 168.8,计算机,198)db.Exec(insertStr)chkERR(err)//_, err exec.RowsAffected() //返回影响的行数,并不是所有数据库都支持,defer db.Close()
}更新数据
// 更新
func (b *BookInfo) updateData() {db, err : sql.Open(mysql, root:123456tcp(172.21.114.22:3306)/gavin?charsetutf8)chkERR(err)updateStr : update bookstore set bookprice109 where booknameGo并发实践exec, err : db.Exec(updateStr) //如果操作成功,返回affected, err : exec.RowsAffected()fmt.Println(update影响行数--, affected)checkError(err)defer db.Close()
}
删除数据
// 删除
func (b *BookInfo) deleteData() {db, err : sql.Open(mysql, root:123456tcp(172.21.114.22:3306)/gavin?charsetutf8)chkERR(err)deleteStr : delete from bookstore where bookprice100 exec, err : db.Exec(deleteStr)affected, err : exec.RowsAffected()fmt.Println(影响行数:, affected)defer db.Close()}
以上操作数据库的方式很容易就会产生sql注入
为此go也为我们提供了预编译的方式来操作数据库; // 预编译的方式插入数据
func preInsert(book BookInfo) (int64, error) {db, err : sql.Open(mysql, root:955945tcp(172.21.114.22:3306)/gavin?)chkERR(err)queryStr : insert into bookstore values (?,?,?,?,?,?)//返回一个预编译的对象prepare, err : db.Prepare(queryStr) //*Stmt, errorchkERR(err)exec, err : prepare.Exec(book.BookId, book.BookName, book.BookPublish, book.BookPrice, book.BookKind, book.BookCount)affected, err : exec.RowsAffected() //返回受影响的行数fmt.Println(受影响的行数---, affected)defer db.Close()if err ! nil {return -1, err}return affected, nil
}
func main() {b : BookInfo{BookId: 1096,BookName: 大雨倾盆,BookPublish: 烟台出版社,BookKind: 小说,BookPrice: 56.5,BookCount: 100,}insert, err : preInsert(b)if err ! nil {return}fmt.Println(insert)
}
结果: 数据库数据: 预编译参数用? 来表示
func preQuery(bookname string) {db, err : sql.Open(mysql, root:955945tcp(172.21.114.22:3306)/gavin?)chkERR(err)queryStr : select * from bookstore where BookName? ;prepare, err : db.Prepare(queryStr)query, err : prepare.Query(bookname) //*Rows, errorb : new(BookInfo)for query.Next() {query.Scan(b.BookId, b.BookName, b.BookPublish, b.BookPrice, b.BookKind, b.BookCount)fmt.Println(*b)}defer query.Close()
}
func main() {preQuery(大雨倾盆)
} db.Query()会从数据库连接池中获取一个连接这个底层连接在结果集rows未关闭前会被标记为处于繁忙状态。当遍历读到最后一条记录时会发生一个内部EOF错误自动调用rows.Close()。但如果出现异常提前退出循环rows不会关闭连接不会回到连接池中连接也不会关闭则此连接会一直被占用。因此通常使用defer rows.Close()来确保数据库连接可以正确放回到连接池中。 在实际开发中应尽量封装 curd这些方法;
但是们实际开发时并不会按照上面的方式去开发,而是借助框架去更快的实现CURD,所以后面要学习Beego框架
