Fixed {Write,Query}Result to set Err properly.

This commit is contained in:
andrew fabbro 2016-09-05 09:59:44 -07:00
parent 84577f05d1
commit f5df4898a3
2 changed files with 4 additions and 4 deletions

View File

@ -159,8 +159,8 @@ func (conn *Connection) Query(sqlStatements []string) (results []QueryResult, er
// did we get an error?
_, ok := thisResult["error"]
if ok {
trace("%s: have an error this this result: %s",conn.ID,thisResult["error"].(string))
thisQR.Err = err
trace("%s: have an error on this result: %s",conn.ID,thisResult["error"].(string))
thisQR.Err = errors.New(thisResult["error"].(string))
results = append(results,thisQR)
numStatementErrors++
continue

View File

@ -127,8 +127,8 @@ func (conn *Connection) Write(sqlStatements []string) (results []WriteResult, er
// did we get an error?
_, ok := thisResult["error"]
if ok {
trace("%s: have an error this this result: %s",conn.ID,thisResult["error"].(string))
thisWR.Err = err
trace("%s: have an error on this result: %s",conn.ID,thisResult["error"].(string))
thisWR.Err = errors.New(thisResult["error"].(string))
results = append(results,thisWR)
numStatementErrors += 1
continue