本教程操作环境：windows7系统、GO 1.18版本、Dell G3电脑。
SQL是什么
(相关资料图)
SQL 是一种操作数据库的语言，包括创建数据库、删除数据库、查询记录、修改记录、添加字段等。SQL 虽然是一种被 ANSI 标准化的语言，但是它有很多不同的实现版本。
SQL 是 Structured Query Language 的缩写，中文译为“结构化查询语言”。SQL 是一种计算机语言，用来存储、检索和修改关系型数据库中存储的数据。
SQL 是关系型数据库的标准语言，所有的关系型数据库管理系统（RDBMS），比如 MySQL、Oracle、SQL Server、MS Access、Sybase、Informix、Postgres 等，都将 SQL 作为其标准处理语言。
SQL 的用途
SQL 之所以广受欢迎，是因为它具有以下用途：
允许用户访问关系型数据库系统中的数据；
允许用户描述数据；
允许用户定义数据库中的数据，并处理该数据；
允许将 SQL 模块、库或者预处理器嵌入到其它编程语言中；
允许用户创建和删除数据库、表、数据项（记录）；
允许用户在数据库中创建视图、存储过程、函数；
允许用户设置对表、存储过程和视图的权限。
Go语言操作数据库（MySQL）
在Go语言标准库提供了进行数据库操作的sql 库，可以利用SQL语言来操作数据库。
go get -u github.com/go-sql-driver/mysql
func Open(driverName, dataSourceName string) (*DB, error)
Open打开一个dirverName指定的数据库，dataSourceName指定数据源，一般至少包括数据库文件名和其它连接必要的信息。
import ("database/sql"_ "github.com/go-sql-driver/mysql")func main() { // DSN:Data Source Namedsn := "user:password@tcp(127.0.0.1:3306)/dbname"db, err := sql.Open("mysql", dsn)if err != nil {panic(err)}defer db.Close() // 注意这行代码要写在上面err判断的下面}Open函数可能只是验证其参数格式是否正确，实际上并不创建与数据库的连接。如果要检查数据源的名称是否真实有效，应该调用Ping方法
package mainimport ("database/sql""fmt"_ "github.com/go-sql-driver/mysql")//需要注意 这里需要引用自己的mysql文件var db *sql.DBfunc initDB()(err error) {//账号 密码 端口号(tcp)127.0.0.1:3306 表名 字符集 校验时间dsn := "root:123456@tcp(127.0.0.1:3306)/gomysql?charset=utf8mb4&parseTime=true"//加载驱动//这里需要是=而不是:=因为我们是给全局变量(db)赋值db,err = sql.Open("mysql",dsn)if err!=nil {return err}//尝试和数据库建立连接(校验dsn正确)//然后用了ping命令err=db.Ping()if err!=nil {return err}return nil}func main() {err := initDB()if err!=nil {fmt.Printf("connect failed,err:%v\n",err)return}}SetMaxOpenConns设置与数据库建立连接的最大数目。 如果n大于0且小于最大闲置连接数，会将最大闲置连接数减小到匹配最大开启连接数的限制。 如果n<=0，不会限制最大开启连接数，默认为0（无限制）
func (db *DB) SetMaxIdleConns(n int)
连接池中的最大闲置连接数
如果n大于最大开启连接数，则新的最大闲置连接数会减小到匹配最大开启连接数的限制。 如果n<=0，不会保留闲置连接。
我们先在MySQL中创建一个名为sql_test的数据库
CREATE DATABASE sql_test;
进入该数据库:
use sql_test;
执行以下命令创建一张用于测试的数据表：
CREATE TABLE `user` ( `id` BIGINT(20) NOT NULL AUTO_INCREMENT, `name` VARCHAR(20) DEFAULT "", `age` INT(11) DEFAULT "0", PRIMARY KEY(`id`))ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4;
单行查询db.QueryRow()执行一次查询，并期望返回最多一行结果（即Row）。QueryRow总是返回非nil的值，直到返回值的Scan方法被调用时，才会返回被延迟的错误。（如：未找到结果）
func (db *DB) QueryRow(query string, args ...interface{}) *Rowfunc queryRowDemo() { sqlStr := "select id, name, age from user where id=?" var u user // 非常重要：确保QueryRow之后调用Scan方法，否则持有的数据库链接不会被释放 err := db.QueryRow(sqlStr, 1).Scan(&u.id, &u.name, &u.age) if err != nil { fmt.Printf("scan failed, err:%v\n", err) return } fmt.Printf("id:%d name:%s age:%d\n", u.id, u.name, u.age)}func (db *DB) Query(query string, args ...interface{}) (*Rows, error)// 查询多条数据示例func queryMultiRowDemo() {sqlStr := "select id, name, age from user where id > ?"rows, err := db.Query(sqlStr, 0)if err != nil {fmt.Printf("query failed, err:%v\n", err)return}// 非常重要：关闭rows释放持有的数据库链接defer rows.Close()// 循环读取结果集中的数据for rows.Next() {var u usererr := rows.Scan(&u.id, &u.name, &u.age)if err != nil {fmt.Printf("scan failed, err:%v\n", err)return}fmt.Printf("id:%d name:%s age:%d\n", u.id, u.name, u.age)}}插入、更新和删除操作都使用Exec方法。
func (db *DB) Exec(query string, args ...interface{}) (Result, error)Exec执行一次命令（包括查询、删除、更新、插入等），返回的Result是对已执行的SQL命令的总结。参数args表示query中的占位参数。
具体插入数据示例代码如下：
// 插入数据func insertRowDemo() {sqlStr := "insert into user(name, age) values (?,?)"ret, err := db.Exec(sqlStr, "王五", 38)if err != nil {fmt.Printf("insert failed, err:%v\n", err)return}theID, err := ret.LastInsertId() // 新插入数据的idif err != nil {fmt.Printf("get lastinsert ID failed, err:%v\n", err)return}fmt.Printf("insert success, the id is %d.\n", theID)}具体更新数据示例代码如下：
// 更新数据func updateRowDemo() {sqlStr := "update user set age=? where id = ?"ret, err := db.Exec(sqlStr, 39, 3)if err != nil {fmt.Printf("update failed, err:%v\n", err)return}n, err := ret.RowsAffected() // 操作影响的行数if err != nil {fmt.Printf("get RowsAffected failed, err:%v\n", err)return}fmt.Printf("update success, affected rows:%d\n", n)}具体删除数据的示例代码如下：
// 删除数据func deleteRowDemo() {sqlStr := "delete from user where id = ?"ret, err := db.Exec(sqlStr, 3)if err != nil {fmt.Printf("delete failed, err:%v\n", err)return}n, err := ret.RowsAffected() // 操作影响的行数if err != nil {fmt.Printf("get RowsAffected failed, err:%v\n", err)return}fmt.Printf("delete success, affected rows:%d\n", n)}package mainimport ("database/sql""fmt"_ "github.com/go-sql-driver/mysql")// 定义一个全局对象dbvar db *sql.DB// 定义一个初始化数据库的函数func initDB() (err error) {// DSN:Data Source Namedsn := "root:123456@tcp(127.0.0.1:3306)/sql_test?charset=utf8&parseTime=True"// 不会校验账号密码是否正确// 注意！！！这里不要使用:=，我们是给全局变量赋值，然后在main函数中使用全局变量dbdb, err = sql.Open("mysql", dsn)if err != nil {return err}// 尝试与数据库建立连接（校验dsn是否正确）err = db.Ping()if err != nil {return err}return nil}type user struct {id intage intname string}func queryRowDemo() {sqlStr := "select id, name, age from user where id=?"var u user// 非常重要：确保QueryRow之后调用Scan方法，否则持有的数据库链接不会被释放err := db.QueryRow(sqlStr, 1).Scan(&u.id, &u.name, &u.age)if err != nil {fmt.Printf("scan failed, err:%v\n", err)return}fmt.Printf("id:%d name:%s age:%d\n", u.id, u.name, u.age)}// 查询多条数据示例func queryMultiRowDemo() {sqlStr := "select id, name, age from user where id > ?"rows, err := db.Query(sqlStr, 0)if err != nil {fmt.Printf("query failed, err:%v\n", err)return}// 非常重要：关闭rows释放持有的数据库链接defer rows.Close()// 循环读取结果集中的数据for rows.Next() {var u usererr := rows.Scan(&u.id, &u.name, &u.age)if err != nil {fmt.Printf("scan failed, err:%v\n", err)return}fmt.Printf("id:%d name:%s age:%d\n", u.id, u.name, u.age)}}func insertRowDemo() {sqlStr := "insert into user(name,age) value (?,?)"//ret,err := db.Exec(sqlStr,"王五",40)if err!=nil {fmt.Printf("inserf failed,err:%v\n",err)return}//插入成功之后需要返回这个idtheID,err:=ret.LastInsertId()if err != nil{fmt.Printf("get the last insertid failed,err:%v\n",theID)return}fmt.Printf("insert success,theID is:%v\n",theID)}func updateRowDemo() {sqlStr := "update user set name =? where id = ?"//执行含有sqlStr参数的语句ret,err:=db.Exec(sqlStr,"赵四",4)if err!=nil {fmt.Printf("update failed,err:%v\n",err)return}AnoID,err:=ret.RowsAffected()if err!=nil {fmt.Printf("updateRowAffected failed,err:%v\n",err)return}fmt.Printf("update success AnoID:%v\n",AnoID)}// 删除数据func deleteRowDemo() {sqlStr := "delete from user where id = ?"ret, err := db.Exec(sqlStr, 5)if err != nil {fmt.Printf("delete failed, err:%v\n", err)return}n, err := ret.RowsAffected() // 操作影响的行数if err != nil {fmt.Printf("get RowsAffected failed, err:%v\n", err)return}fmt.Printf("delete success, affected rows:%d\n", n)}func main() {err := initDB() // 调用输出化数据库的函数if err != nil {fmt.Printf("init db failed,err:%v\n", err)return}//queryRowDemo()//insertRowDemo() //updateRowDemo() deleteRowDemo()queryMultiRowDemo()}普通SQL语句执行过程：
客户端对SQL语句进行占位符替换得到完整的SQL语句。
客户端发送完整SQL语句到MySQL服务端
MySQL服务端执行完整的SQL语句并将结果返回给客户端。
预处理执行过程：
把SQL语句分成两部分，命令部分与数据部分。
先把命令部分发送给MySQL服务端，MySQL服务端进行SQL预处理。
然后把数据部分发送给MySQL服务端，MySQL服务端对SQL语句进行占位符替换。
MySQL服务端执行完整的SQL语句并将结果返回给客户端
优化MySQL服务器重复执行SQL的方法，可以提升服务器性能，提前让服务器编译，一次编译多次执行，节省后续编译的成本。
避免SQL注入问题。
func (db *DB) Prepare(query string) (*Stmt, error)
查询操作的预处理示例代码如下：
// 预处理查询示例func prepareQueryDemo() {sqlStr := "select id, name, age from user where id > ?"stmt, err := db.Prepare(sqlStr)if err != nil {fmt.Printf("prepare failed, err:%v\n", err)return}defer stmt.Close()rows, err := stmt.Query(0)if err != nil {fmt.Printf("query failed, err:%v\n", err)return}defer rows.Close()// 循环读取结果集中的数据for rows.Next() {var u usererr := rows.Scan(&u.id, &u.name, &u.age)if err != nil {fmt.Printf("scan failed, err:%v\n", err)return}fmt.Printf("id:%d name:%s age:%d\n", u.id, u.name, u.age)}}插入、更新和删除操作的预处理十分类似，这里以插入操作的预处理为例：
// 预处理插入示例func prepareInsertDemo() {sqlStr := "insert into user(name, age) values (?,?)"stmt, err := db.Prepare(sqlStr)if err != nil {fmt.Printf("prepare failed, err:%v\n", err)return}defer stmt.Close()_, err = stmt.Exec("小王子", 18)if err != nil {fmt.Printf("insert failed, err:%v\n", err)return}_, err = stmt.Exec("沙河娜扎", 18)if err != nil {fmt.Printf("insert failed, err:%v\n", err)return}fmt.Println("insert success.")}我们任何时候都不应该自己拼接SQL语句！
// sql注入示例func sqlInjectDemo(name string) {sqlStr := fmt.Sprintf("select id, name, age from user where name="%s"", name)fmt.Printf("SQL:%s\n", sqlStr)var u usererr := db.QueryRow(sqlStr).Scan(&u.id, &u.name, &u.age)if err != nil {fmt.Printf("exec failed, err:%v\n", err)return}fmt.Printf("user:%#v\n", u)}此时以下输入字符串都可以引发SQL注入问题：
sqlInjectDemo("xxx" or 1=1#")sqlInjectDemo("xxx" union select * from user #")sqlInjectDemo("xxx" and (select count(*) from user) <10 #")| 数据库 | 占位符语法 |
|---|---|
| MySQL | ? |
| PostgreSQL | $1, $2等 |
| SQLite | ?和$1 |
| Oracle | :name |
以上就是go语言中sql是什么的详细内容，更多请关注php中文网其它相关文章！
营业执照公示信息