-
Notifications
You must be signed in to change notification settings - Fork 52
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
refactor(sql-execute): refactor SQL async execute api into streaming return #2246
Conversation
server/odc-core/src/main/java/com/oceanbase/odc/core/session/ConnectionSessionUtil.java
Show resolved
Hide resolved
server/odc-core/src/main/java/com/oceanbase/odc/core/session/ConnectionSessionUtil.java
Show resolved
Hide resolved
server/odc-core/src/main/java/com/oceanbase/odc/core/session/ConnectionSessionUtil.java
Outdated
Show resolved
Hide resolved
.../odc-service/src/main/java/com/oceanbase/odc/service/connection/util/ConnectionInfoUtil.java
Outdated
Show resolved
Hide resolved
.../odc-service/src/main/java/com/oceanbase/odc/service/connection/util/ConnectionInfoUtil.java
Outdated
Show resolved
Hide resolved
server/odc-service/src/main/java/com/oceanbase/odc/service/session/ConnectConsoleService.java
Outdated
Show resolved
Hide resolved
server/odc-service/src/main/java/com/oceanbase/odc/service/session/ConnectConsoleService.java
Outdated
Show resolved
Hide resolved
server/odc-service/src/main/java/com/oceanbase/odc/service/session/ConnectConsoleService.java
Outdated
Show resolved
Hide resolved
...r/odc-service/src/main/java/com/oceanbase/odc/service/session/model/AsyncExecuteContext.java
Outdated
Show resolved
Hide resolved
pr gets conflict with dev/4.3.x |
server/odc-core/src/main/java/com/oceanbase/odc/core/session/ConnectionSessionUtil.java
Show resolved
Hide resolved
.../odc-service/src/main/java/com/oceanbase/odc/service/connection/util/ConnectionInfoUtil.java
Outdated
Show resolved
Hide resolved
server/odc-service/src/main/java/com/oceanbase/odc/service/session/ConnectConsoleService.java
Outdated
Show resolved
Hide resolved
server/odc-service/src/main/java/com/oceanbase/odc/service/session/ConnectConsoleService.java
Outdated
Show resolved
Hide resolved
server/odc-service/src/main/java/com/oceanbase/odc/service/session/ConnectConsoleService.java
Outdated
Show resolved
Hide resolved
...r/odc-service/src/main/java/com/oceanbase/odc/service/session/model/AsyncExecuteContext.java
Outdated
Show resolved
Hide resolved
server/odc-service/src/main/java/com/oceanbase/odc/service/session/OdcStatementCallBack.java
Outdated
Show resolved
Hide resolved
server/odc-service/src/main/java/com/oceanbase/odc/service/session/OdcStatementCallBack.java
Outdated
Show resolved
Hide resolved
server/odc-service/src/main/java/com/oceanbase/odc/service/session/OdcStatementCallBack.java
Outdated
Show resolved
Hide resolved
server/odc-service/src/main/java/com/oceanbase/odc/service/session/OdcStatementCallBack.java
Show resolved
Hide resolved
…mu_430_feat_refactor_async_execute
…mu_430_feat_refactor_async_execute # Conflicts: # server/odc-service/src/main/java/com/oceanbase/odc/service/session/OdcStatementCallBack.java
server/odc-service/src/main/java/com/oceanbase/odc/service/session/ConnectConsoleService.java
Outdated
Show resolved
Hide resolved
server/odc-service/src/main/java/com/oceanbase/odc/service/session/ConnectConsoleService.java
Outdated
Show resolved
Hide resolved
server/odc-service/src/main/java/com/oceanbase/odc/service/session/OdcStatementCallBack.java
Outdated
Show resolved
Hide resolved
server/odc-service/src/main/java/com/oceanbase/odc/service/session/SqlExecutionListener.java
Outdated
Show resolved
Hide resolved
...r/odc-service/src/main/java/com/oceanbase/odc/service/session/model/AsyncExecuteContext.java
Outdated
Show resolved
Hide resolved
...r/odc-service/src/main/java/com/oceanbase/odc/service/session/model/AsyncExecuteContext.java
Outdated
Show resolved
Hide resolved
...r/odc-service/src/main/java/com/oceanbase/odc/service/session/model/AsyncExecuteContext.java
Outdated
Show resolved
Hide resolved
...r/odc-service/src/main/java/com/oceanbase/odc/service/session/model/AsyncExecuteContext.java
Outdated
Show resolved
Hide resolved
...r/odc-service/src/main/java/com/oceanbase/odc/service/session/model/AsyncExecuteContext.java
Outdated
Show resolved
Hide resolved
...r/odc-service/src/main/java/com/oceanbase/odc/service/session/model/AsyncExecuteContext.java
Show resolved
Hide resolved
server/odc-service/src/main/java/com/oceanbase/odc/service/session/OdcStatementCallBack.java
Show resolved
Hide resolved
server/odc-service/src/main/java/com/oceanbase/odc/service/session/ConnectConsoleService.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
lgtm
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
lgtm
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
server/odc-core/src/main/java/com/oceanbase/odc/core/session/ConnectionSessionUtil.java
Show resolved
Hide resolved
...erver/src/main/java/com/oceanbase/odc/server/web/controller/v2/ConnectSessionController.java
Outdated
Show resolved
Hide resolved
...erver/src/main/java/com/oceanbase/odc/server/web/controller/v2/ConnectSessionController.java
Outdated
Show resolved
Hide resolved
.../odc-service/src/main/java/com/oceanbase/odc/service/connection/util/ConnectionInfoUtil.java
Show resolved
Hide resolved
server/odc-service/src/main/java/com/oceanbase/odc/service/session/ConnectConsoleService.java
Show resolved
Hide resolved
server/odc-service/src/main/java/com/oceanbase/odc/service/session/ConnectConsoleService.java
Outdated
Show resolved
Hide resolved
1ab297d
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
lgtm
What type of PR is this?
type-feature
What this PR does / why we need it:
In ODC 4.3.0, We hope to refactor the SQL async execute api into a streaming return method. Each time, it returns the results that has already been finished.
Therefore, I added a
AsyncExecuteContext
to cache the results ofODCStatementCallBack
.When the ODC server receives a request for
getResult
, it will first block for one second to determine whether the SQL execution is complete.If the execution is completed, the result will be directly returned. The status is SUCCESS.
If it is not completed, the results completed during the period from the last request to now will be returned. At this point, the status is RUNNING.