|
@@ -144,7 +144,7 @@ func (m *BaseFromThsHfIndex) RemoveByCondition(condition string, pars []interfac
|
|
|
//o := orm.NewOrm()
|
|
|
sql := fmt.Sprintf(`DELETE FROM %s WHERE %s`, m.TableName(), condition)
|
|
|
//_, err = o.Raw(sql, pars).Exec()
|
|
|
- err = global.DEFAULT_DmSQL.Exec(sql, pars).Error
|
|
|
+ err = global.DEFAULT_DmSQL.Exec(sql, pars...).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -164,7 +164,7 @@ func (m *BaseFromThsHfIndex) GetItemByCondition(condition string, pars []interfa
|
|
|
}
|
|
|
sql := fmt.Sprintf(`SELECT * FROM %s WHERE 1=1 %s %s LIMIT 1`, m.TableName(), condition, order)
|
|
|
//err = o.Raw(sql, pars).QueryRow(&item)
|
|
|
- err = global.DEFAULT_DmSQL.Raw(sql, pars).First(&item).Error
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, pars...).First(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -172,7 +172,7 @@ func (m *BaseFromThsHfIndex) GetCountByCondition(condition string, pars []interf
|
|
|
//o := orm.NewOrm()
|
|
|
sql := fmt.Sprintf(`SELECT COUNT(1) FROM %s WHERE 1=1 %s`, m.TableName(), condition)
|
|
|
//err = o.Raw(sql, pars).QueryRow(&count)
|
|
|
- err = global.DEFAULT_DmSQL.Raw(sql, pars).Scan(&count).Error
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, pars...).Scan(&count).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -188,7 +188,7 @@ func (m *BaseFromThsHfIndex) GetItemsByCondition(condition string, pars []interf
|
|
|
}
|
|
|
sql := fmt.Sprintf(`SELECT %s FROM %s WHERE 1=1 %s %s`, fields, m.TableName(), condition, order)
|
|
|
//_, err = o.Raw(sql, pars).QueryRows(&items)
|
|
|
- err = global.DEFAULT_DmSQL.Raw(sql, pars).Find(&items).Error
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, pars...).Find(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -204,6 +204,8 @@ func (m *BaseFromThsHfIndex) GetPageItemsByCondition(condition string, pars []in
|
|
|
}
|
|
|
sql := fmt.Sprintf(`SELECT %s FROM %s WHERE 1=1 %s %s LIMIT ?,?`, fields, m.TableName(), condition, order)
|
|
|
//_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
|
|
|
- err = global.DEFAULT_DmSQL.Raw(sql, pars, startSize, pageSize).Find(&items).Error
|
|
|
+
|
|
|
+ pars = append(pars, startSize, pageSize)
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, pars...).Find(&items).Error
|
|
|
return
|
|
|
}
|