feat: 导出DollarNParamBindWrapper

This commit is contained in:
qbhy
2023-02-01 10:10:51 +08:00
parent 83eb8e5d6b
commit e4f1f2751e
2 changed files with 3 additions and 3 deletions

View File

@@ -24,7 +24,7 @@ func (c Clickhouse) Transaction(f func(executor contracts.SqlExecutor) error) er
return errors.New("transaction is not supported")
}
func dollarNParamBindWrapper(sql string) (result string) {
func DollarNParamBindWrapper(sql string) (result string) {
var (
parts = strings.Split(sql, "?")
partsLen = len(parts)
@@ -77,6 +77,6 @@ func ClickHouseConnector(config contracts.Fields, events contracts.EventDispatch
db.SetMaxOpenConns(utils.GetIntField(config, "max_connections"))
db.SetMaxIdleConns(utils.GetIntField(config, "max_idles"))
return &Clickhouse{
support.NewExecutor(db, events, dollarNParamBindWrapper),
support.NewExecutor(db, events, DollarNParamBindWrapper),
}
}

View File

@@ -28,5 +28,5 @@ func PostgresSqlConnector(config contracts.Fields, events contracts.EventDispatc
db.SetMaxOpenConns(utils.GetIntField(config, "max_connections"))
db.SetMaxIdleConns(utils.GetIntField(config, "max_idles"))
return &PostgresSQL{WithWrapper(db, events, dollarNParamBindWrapper)}
return &PostgresSQL{WithWrapper(db, events, DollarNParamBindWrapper)}
}