【问题标题】:Making dynamic SQL queries to a MySQL DB对 MySQL 数据库进行动态 SQL 查询
【发布时间】:2018-04-02 06:01:43
【问题描述】:

我以前从未在 mysql 中使用过 golang,所以我是第一次阅读这些内容。我想做这样的事情:

if userId && gender && age
db.QueryRow("SELECT name FROM users WHERE userId=? AND gender=? AND age=?", userId,gender,age)
else if gender && age
db.QueryRow("SELECT name FROM users WHERE gender=? AND age=?", gender, age)
else if userId && gender
db.QueryRow("SELECT name FROM users WHERE userId=? AND gender=?", userId,gender)
else if userId && age
db.QueryRow("SELECT name FROM users WHERE userId=? AND age=?", userId, age)
else if gender
db.QueryRow("SELECT name FROM users WHERE gender=?", gender)
else if userId
db.QueryRow("SELECT name FROM users WHERE userId=?", userId)
else if age
db.QueryRow("SELECT name FROM users WHERE age=?", age)

这是太多的输入,尤其是如果我有十几个变量要添加到 WHERE 条件中。

如果这是 PHP,我会这样做:

$sql = "SELECT name FROM users ";
$where = array();
foreach(explode(",","userId,gender,age,name,height,weight,ethnicity" as $field)
{
    if(isset($arrayOfValues[$field]))
    {
        $where[count($where)] = $field." = ?".$field
        $db->bind("?".$field,$arrayOfValues[$field]);
    }
}

if(count($where)>0)
$sql = $sql . " WHERE ".implode(" AND ",$where);
$db->query($sql);

通过使用 foreach 循环,我可以动态生成查询并根据需要动态绑定尽可能多的变量。

golang 和 mysql 有类似的选项吗?或者是否有替代方法可以不为查询输入每个变量组合?

【问题讨论】:

  • 您也可以使用 ORM,例如 github.com/jinzhu/gorm,它可以让您基于部分填充的结构进行查询。

标签: mysql sql go


【解决方案1】:

如果您有这样的字段名称和值的地图:

m := map[string]interface{}{"UserID": 1234, "Age": 18}

然后您可以像这样构建查询:

var values []interface{}
var where []string
for _, k := range []string{"userId", "gender", "age", "name", "height", "weight", "ethnicity"} {
    if v, ok := m[k]; ok {
        values = append(values, v)
        where = append(where, fmt.Sprintf("%s = ?", k))
    }
}
r, err := db.QueryRow("SELECT name FROM users WHERE " + strings.Join(where, " AND "), values...)

这不易受到 SQL 注入的影响,因为占位符用于应用程序直接控制之外的部分查询。

如果已知映射键是允许的字段名称,则使用此:

var values []interface{}
var where []string
for k, v := range m {
    values = append(values, v)
    where = append(where, fmt.Sprintf("%s = ?", k))
}
r, err := db.QueryRow("SELECT name FROM users WHERE " + strings.Join(where, " AND "), values...)

【讨论】:

  • 正要批评 SQL 注入,但这个解决方案实际上确实限制了字符串操作的代码中的内容......据我所知。
  • 我也是这样用的!
猜你喜欢
  • 2019-12-17
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2020-03-08
  • 2021-09-20
  • 1970-01-01
  • 2016-09-01
相关资源
最近更新 更多