Skip to content

Commit 17fd2cc

Browse files
author
Miguel Molina
authored
Merge pull request #135 from erizocosmico/fix/use-proxy-in-store-ops
always use the proxy in all store operations instead of raw database
2 parents 26fcb7f + c23c808 commit 17fd2cc

File tree

2 files changed

+97
-73
lines changed

2 files changed

+97
-73
lines changed

store.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -217,7 +217,7 @@ func (s *Store) Delete(schema Schema, record Record) error {
217217
// WARNING: A result set created from a raw query can only be scanned using the
218218
// RawScan method of ResultSet, instead of Scan.
219219
func (s *Store) RawQuery(sql string, params ...interface{}) (ResultSet, error) {
220-
rows, err := s.db.Query(sql, params...)
220+
rows, err := s.proxy.Query(sql, params...)
221221
if err != nil {
222222
return nil, err
223223
}
@@ -228,7 +228,7 @@ func (s *Store) RawQuery(sql string, params ...interface{}) (ResultSet, error) {
228228
// RawExec executes a raw SQL query with the given parameters and returns
229229
// the number of affected rows.
230230
func (s *Store) RawExec(sql string, params ...interface{}) (int64, error) {
231-
result, err := s.db.Exec(sql, params...)
231+
result, err := s.proxy.Exec(sql, params...)
232232
if err != nil {
233233
return 0, err
234234
}
@@ -252,7 +252,7 @@ func (s *Store) Find(q Query) (ResultSet, error) {
252252
builder = builder.Limit(limit)
253253
}
254254

255-
rows, err := builder.RunWith(s.db).Query()
255+
rows, err := builder.RunWith(s.proxy).Query()
256256
if err != nil {
257257
return nil, err
258258
}

0 commit comments

Comments
 (0)