|
|
@ -458,10 +458,12 @@ func (s *Store) Execute(ex *ExecuteRequest) ([]*sql.Result, error) {
|
|
|
|
func (s *Store) ExecuteOrAbort(ex *ExecuteRequest) (results []*sql.Result, retErr error) {
|
|
|
|
func (s *Store) ExecuteOrAbort(ex *ExecuteRequest) (results []*sql.Result, retErr error) {
|
|
|
|
defer func() {
|
|
|
|
defer func() {
|
|
|
|
var errored bool
|
|
|
|
var errored bool
|
|
|
|
for i := range results {
|
|
|
|
if results != nil {
|
|
|
|
if results[i].Error != "" {
|
|
|
|
for i := range results {
|
|
|
|
errored = true
|
|
|
|
if results[i].Error != "" {
|
|
|
|
break
|
|
|
|
errored = true
|
|
|
|
|
|
|
|
break
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if retErr != nil || errored {
|
|
|
|
if retErr != nil || errored {
|
|
|
|