|
|
@ -741,11 +741,9 @@ func (db *DB) Request(req *command.Request, xTime bool) ([]*command.ExecuteQuery
|
|
|
|
ro, err := db.StmtReadOnly(ss)
|
|
|
|
ro, err := db.StmtReadOnly(ss)
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
eqResponse = append(eqResponse, &command.ExecuteQueryResponse{
|
|
|
|
eqResponse = append(eqResponse, &command.ExecuteQueryResponse{
|
|
|
|
Result: &command.ExecuteQueryResponse_Q{
|
|
|
|
Result: &command.ExecuteQueryResponse_Error{
|
|
|
|
Q: &command.QueryRows{
|
|
|
|
|
|
|
|
Error: err.Error(),
|
|
|
|
Error: err.Error(),
|
|
|
|
},
|
|
|
|
},
|
|
|
|
},
|
|
|
|
|
|
|
|
})
|
|
|
|
})
|
|
|
|
continue
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
}
|
|
|
|