Skip to content

Sessionless transactions demo #442

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.

Sign up for GitHub

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

Merged
merged 7 commits into from
May 23, 2025
Merged

Sessionless transactions demo #442

Changes from 1 commit
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
1fa681e
Sessionless transactions demo
meedbek Apr 28, 2025
8b783e1
Rollback if start transaction request fails
meedbek May 2, 2025
a80d19e
Merge branch 'oracle-samples:main' into sessionless-txns-demo
meedbek May 2, 2025
c12eba0
Remove DTO suffix
meedbek May 5, 2025
bb2353e
Remove fixme
meedbek May 5, 2025
ef3814b
Update copyright
meedbek May 21, 2025
f4470f3
Add concurrency tests
meedbek May 22, 2025
File filter

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Rollback if start transaction request fails
  • Loading branch information
@meedbek
meedbek committed May 2, 2025
commit 8b783e1e6f656e932c822f95cd6777dbe236d647
3 changes: 2 additions & 1 deletion ...actions/src/main/java/com/oracle/jdbc/samples/sessionlesstxns/service/BookingService.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -41,13 +41,14 @@ public BookingService(DataSource dataSource, @SuppressWarnings("SpringJavaInject

public StartTransactionResponseDTO startTransaction(StartTransactionRequestDTO body) {
try (OracleConnection conn = (OracleConnection) connectionPool.getConnection();
AutoCloseable suspend = conn::suspendTransaction;) {
AutoCloseable rollback = conn::rollback;) {
conn.setAutoCommit(false);
byte[] gtrid = conn.startTransaction(body.timeout() * 60);

long bookingId = createBooking(conn);

List<Long> seats = lockAndBookSeats(conn, bookingId, body.flightId(), body.count());
conn.suspendTransaction();

return new StartTransactionResponseDTO(bookingId, Util.byteArrayToHex(gtrid), seats.size(), seats);
} catch (APIException ex) {
Expand Down