天元太保 發表於 2020-2-28 11:06:00

Go语言SQL注入和防注入

<h1 id="go语言sql注入和防注入">Go语言SQL注入和防注入</h1>
<h3 id="一sql注入是什么">一、SQL注入是什么</h3>
<p>SQL注入是一种注入攻击手段,通过执行恶意SQL语句,进而将任意SQL代码插入数据库查询,从而使攻击者完全控制Web应用程序后台的数据库服务器。攻击者可以使用SQL注入漏洞绕过应用程序验证,比如绕过登录验证登录Web身份验证和授权页面;也可以绕过网页,直接检索数据库的所有内容;还可以恶意修改、删除和增加数据库内容。</p>
<h3 id="二防止sql注入的思路和方法">二、防止SQl注入的思路和方法</h3>
<ul>
<li>1.永远不要信任用户的输入。对用户的输入进行校验,可以通过正则表达式,或限制长度;对单引号和 双"-"进行转换等。</li>
<li>2.永远不要使用动态拼装SQL,可以使用参数化的SQL或者直接使用存储过程进行数据查询存取。</li>
<li>3.永远不要使用管理员权限的数据库连接,为每个应用使用单独的权限有限的数据库连接。</li>
<li>4.不要把机密信息直接存放,加密或者hash掉密码和敏感的信息。</li>
<li>5.应用的异常信息应该给出尽可能少的提示,最好使用自定义的错误信息对原始错误信息进行包装</li>
<li>6.sql注入的检测方法一般采取辅助软件或网站平台来检测,软件一般采用sql注入检测工具jsky,网站平台就有亿思网站安全平台检测工具。MDCSOFT SCAN等。采用MDCSOFT-IPS可以有效的防御SQL注入,XSS攻击等。</li>
</ul>
<h3 id="三go语言防止sql注入的方法">三、Go语言防止SQL注入的方法</h3>
<p>我们采取了第二条思路和方法,即不用动态拼接SQL语句的方法,而是使用参数化查询,即变量绑定。</p>
<p>下面给出SQL注入攻击安全漏洞代码——拼接SQL语句:</p>
<pre><code class="language-sql">//数据库
/*
Navicat Premium Data Transfer

Source Server         : localhost_3306
Source Server Type    : MySQL
Source Server Version : 50553
Source Host         : localhost:3306
Source Schema         : test

Target Server Type    : MySQL
Target Server Version : 50553
File Encoding         : 65001

Date: 28/02/2020 10:48:06
*/

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
-- Table structure for userinfo
-- ----------------------------
DROP TABLE IF EXISTS `userinfo`;
CREATE TABLE `userinfo`(
`uid` int(10) NOT NULL AUTO_INCREMENT,
`username` varchar(64) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
`password` varchar(64) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
PRIMARY KEY (`uid`) USING BTREE
) ENGINE = MyISAM AUTO_INCREMENT = 14 CHARACTER SET = latin1 COLLATE = latin1_swedish_ci ROW_FORMAT = Dynamic;

-- ----------------------------
-- Records of userinfo
-- ----------------------------
INSERT INTO `userinfo` VALUES (2, 'aaa', 'hh');
INSERT INTO `userinfo` VALUES (4, 'ast', 'dddd');

SET FOREIGN_KEY_CHECKS = 1;

</code></pre>
<pre><code class="language-go">//test.go
package main

import (
        "database/sql"
        "fmt"
        _ "github.com/go-sql-driver/mysql"
        "html/template"
        "log"
        "net/http"
        "strings"
)
func login(w http.ResponseWriter, r *http.Request) {
        fmt.Println("method:", r.Method) //获取请求的方法
        if r.Method == "GET" {
                t, _ := template.ParseFiles("D:/Golang/GoItem/go_ex/goSql/test.html")
                t.Execute(w, nil)
        } else {
                //请求的是查询数据,那么执行查询的逻辑判断
                r.ParseForm()
                fmt.Println("username:", r.Form["username"])
                var sename = strings.Join(r.Form["username"], "")
                var partname = strings.Join(r.Form["password"], "")
                db, err := sql.Open("mysql", "root:123456@/test?charset=utf8")
                infoErr(err)
                if sename != "" &amp;&amp; partname != "" {
                        var uid int
                        var username string
                        var password string
                        //字符串拼接查询
                        err := db.QueryRow("SELECT * FROM userinfo WHERE username ='"+sename+"'AND password ='"+partname+"'").
                                Scan(&amp;uid, &amp;username, &amp;password)
                        infoErr(err)
                        //判断返回的数据是否为空
                        if err == sql.ErrNoRows {
                                fmt.Fprintf(w, "无该用户数据")
                        } else {
                                if (sename == username) &amp;&amp; (partname == password) {
                                        fmt.Println(uid)
                                        fmt.Println(username)
                                        fmt.Println(password)
                                        t, _ := template.ParseFiles("D:/Golang/GoItem/go_ex/goSql/success.html")
                                        t.Execute(w, nil)
                                }
                        }
                } else if sename == "" || partname == "" {
                        fmt.Fprintf(w, "错误,输入不能为空!")
                }

        }

}


func infoErr(err error) {
        if err != nil {
                panic(err)
        }
}

func main() {
        http.HandleFunc("/login",login)   //设置访问的路由         //设置访问的路由
        err := http.ListenAndServe(":9092", nil) //设置监听的端口
        if err != nil {
                log.Fatal("ListenAndServe: ", err)
        }
}
</code></pre>
<pre><code class="language-html">//login.html
&lt;html&gt;
&lt;head&gt;
    &lt;meta charset="utf-8" /&gt;
    &lt;title&gt;sql防注入&lt;/title&gt;
    &lt;style&gt;
      form{
            width: 30vw;
            height: 30vh;
            min-height: 300px;
            margin: 10vh auto;
            border: 1px solid;
            border-radius: 4px;
      }
      form .username,.password{
         display: block;
            float: right;
      }
      div {
            width: 300px;
            height: 80px;
            margin: 30px auto 0;
      }
      input label {
            float: left;
            display: inline-block;
      }
      input {
            height: 30px;
      }
      .button {
            width: 100px;
            margin: auto;
            clear: both;
            display: block;
      }
    &lt;/style&gt;
&lt;/head&gt;
&lt;body&gt;
&lt;form action="/login" method="post"&gt;
    &lt;div&gt;
      &lt;label&gt;username: &lt;/label&gt;
      &lt;input class="username" type="text" name="username"&gt;
    &lt;/div&gt;
    &lt;div&gt;
      &lt;label&gt;password:&lt;/label&gt;
      &lt;input class="password" type="text" name="password"&gt;
    &lt;/div&gt;
    &lt;input class="button" type="submit" value="查询"&gt;
&lt;/form&gt;
&lt;/body&gt;
&lt;/html&gt;
</code></pre>
<p>解决防SQL注入方案——参数化查询:</p>
<pre><code class="language-go">//test.go
package main

import (
        "database/sql"
        "fmt"
        _ "github.com/go-sql-driver/mysql"
        "html/template"
        "log"
        "net/http"
        "strings"
)

func login(w http.ResponseWriter, r *http.Request) {
        fmt.Println("method:", r.Method) //获取请求的方法
        if r.Method == "GET" {
                t, _ := template.ParseFiles("D:/Golang/GoItem/go_ex/goSql/login.html")
                t.Execute(w, nil)
        } else {
                //请求的是查询数据,那么执行查询的逻辑判断
                r.ParseForm()
                fmt.Println("username:", r.Form["username"])
                var sename = strings.Join(r.Form["username"], "")
                var partname = strings.Join(r.Form["password"], "")
                db, err := sql.Open("mysql", "root:123456@/test?charset=utf8")
                checkErr(err)
                if sename != "" &amp;&amp; partname != "" {
                        var uid int
                        var username string
                        var password string
            //参数查询在一定程度上防止sql注入,参数化查询主要做了两件事:
                        //1.参数过滤;2.执行计划重用
                        //因为执行计划被重用,所以可以防止SQL注入。
                        err := db.QueryRow("SELECT * FROM userinfo WHERE username = ? AND password = ?", sename, partname).
                                Scan(&amp;uid, &amp;username, &amp;password)
                        //判断返回的数据是否为空
                        if err == sql.ErrNoRows {
                                fmt.Fprintf(w, "无该用户数据")
                        } else {
                                if (sename == username) &amp;&amp; (partname == password) {
                                        fmt.Println(uid)
                                        fmt.Println(username)
                                        fmt.Println(password)
                                        t, _ := template.ParseFiles("D:/Golang/GoItem/go_ex/goSQL/success.html")
                                        t.Execute(w, nil)
                                }
                        }
                } else if sename == "" || partname == "" {
                        fmt.Fprintf(w, "错误,输入不能为空!")
                }

        }

}

func checkErr(err error) {
        if err != nil {
                panic(err)
        }
}

func main() {
        http.HandleFunc("/login", login)   //设置访问的路由
        err := http.ListenAndServe(":9090", nil) //设置监听的端口
        if err != nil {
                log.Fatal("ListenAndServe: ", err)
        }
}

</code></pre>
<h3 id="四sql注入判断">四、SQL注入判断</h3>
<p>执行登录查询的数据库语句:<code>"SELECT * FROM userinfo WHERE username ='"+sename+"'AND password ='"+partname+"'"</code></p>
<p>当查询到数据表中存在同时满足 username 和 password 字段时,会返回用户信息。 尝试在用户名中输入 123' or 1=1 #, 密码同样输入 123' or 1=1 # ,实际执行的SQL语句是<code>select * from users where username='123' or '1'='1' and password='123' or '1'='1</code></p>
<p>则会出现一个空白页面,其实此时SQl注入已经绕过验证进入到需要身份验证的页面。</p>
<p>而如果执行<code>"SELECT * FROM userinfo WHERE username = ? AND password = ?", sename, partname</code></p>
<p>再次输入123' or 1=1 #,则会被拦截下来,<strong>显示无该用户数据</strong>。</p>
<h3 id="五为什么参数化查询会防止sql注入">五、为什么参数化查询会防止SQL注入</h3>
<p>我们需要知道参数化查询都做了些什么事:</p>
<p><strong>1.参数过滤</strong>;</p>
<p><strong>2.执行计划重用</strong></p>
<p>它的原理是采用了预编译的方法,先将SQL语句中可被客户端控制的参数集进行编译,生成对应的临时变量集,再使用对应的设置方法,为临时变量集里面的元素进行赋值,而QueryRow()方法会对传入参数进行强制类性检查和安全检查,所以就避免了SQL注入的产生。</p>
<pre><code class="language-go">QueryRow("SELECT * FROM userinfo WHERE username = ? AND password = ?", sename, partname).
                                Scan(&amp;uid, &amp;username, &amp;password)
</code></pre><br><br>
来源:https://www.cnblogs.com/mogebw/p/12376268.html
頁: [1]
查看完整版本: Go语言SQL注入和防注入