diff --git a/drivers/clickhouse.go b/drivers/clickhouse.go index 4b17bbf..1ca98cd 100644 --- a/drivers/clickhouse.go +++ b/drivers/clickhouse.go @@ -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), } } diff --git a/drivers/postgresql.go b/drivers/postgresql.go index b4647c7..6df5b9b 100644 --- a/drivers/postgresql.go +++ b/drivers/postgresql.go @@ -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)} }