agent_patch
runs/2026-02-28__18-27-22__gpt-5-1-codex-mini/flux-pr-1649/flux-pr-1649.1-of-1.2026-02-28__18-27-22__gpt-5-1-codex-mini/agent-logs/agent.patch
9832 bytes
diff --git a/tmp/agent-patch-flux-pr-1649.1-of-1.2026-02-28__18-27-22__gpt-5-1-codex-mini/app/src/ast/helpers/stmt_create_table.rs b/app/src/ast/helpers/stmt_create_table.rs
index 364969c..2a0663b 100644
--- a/tmp/agent-patch-flux-pr-1649.1-of-1.2026-02-28__18-27-22__gpt-5-1-codex-mini/app/src/ast/helpers/stmt_create_table.rs
+++ b/app/src/ast/helpers/stmt_create_table.rs
@@ -548,7 +548,10 @@ mod tests {
#[test]
pub fn test_from_invalid_statement() {
- let stmt = Statement::Commit { chain: false };
+ let stmt = Statement::Commit {
+ chain: false,
+ modifier: None,
+ };
assert_eq!(
CreateTableBuilder::try_from(stmt).unwrap_err(),
diff --git a/tmp/agent-patch-flux-pr-1649.1-of-1.2026-02-28__18-27-22__gpt-5-1-codex-mini/app/src/ast/mod.rs b/app/src/ast/mod.rs
index 6d0ef42..a77e24a 100644
--- a/tmp/agent-patch-flux-pr-1649.1-of-1.2026-02-28__18-27-22__gpt-5-1-codex-mini/app/src/ast/mod.rs
+++ b/app/src/ast/mod.rs
@@ -2958,7 +2958,8 @@ pub enum Statement {
modes: Vec<TransactionMode>,
begin: bool,
transaction: Option<BeginTransactionKind>,
- /// Only for SQLite
+ /// Transaction modifiers used by SQLite (`DEFERRED`/`IMMEDIATE`/`EXCLUSIVE`)
+ /// and MS SQL (`TRY`/`CATCH`).
modifier: Option<TransactionModifier>,
},
/// ```sql
@@ -2985,7 +2986,11 @@ pub enum Statement {
/// ```sql
/// COMMIT [ TRANSACTION | WORK ] [ AND [ NO ] CHAIN ]
/// ```
- Commit { chain: bool },
+ /// SQLite or MS SQL transaction modifiers are captured via `modifier`.
+ Commit {
+ chain: bool,
+ modifier: Option<TransactionModifier>,
+ },
/// ```sql
/// ROLLBACK [ TRANSACTION | WORK ] [ AND [ NO ] CHAIN ] [ TO [ SAVEPOINT ] savepoint_name ]
/// ```
@@ -4614,8 +4619,18 @@ impl fmt::Display for Statement {
}
Ok(())
}
- Statement::Commit { chain } => {
- write!(f, "COMMIT{}", if *chain { " AND CHAIN" } else { "" },)
+ Statement::Commit { chain, modifier } => {
+ if let Some(modifier) = modifier {
+ write!(f, "COMMIT {modifier}")?;
+ } else {
+ write!(f, "COMMIT")?;
+ }
+
+ if *chain {
+ write!(f, " AND CHAIN")?;
+ }
+
+ Ok(())
}
Statement::Rollback { chain, savepoint } => {
write!(f, "ROLLBACK")?;
@@ -6388,7 +6403,7 @@ impl fmt::Display for TransactionIsolationLevel {
}
}
-/// SQLite specific syntax
+/// Transaction modifiers supported by SQLite terminal and MS SQL TRY/CATCH blocks.
///
/// <https://sqlite.org/lang_transaction.html>
#[derive(Debug, Copy, Clone, PartialEq, PartialOrd, Eq, Ord, Hash)]
@@ -6398,6 +6413,8 @@ pub enum TransactionModifier {
Deferred,
Immediate,
Exclusive,
+ Try,
+ Catch,
}
impl fmt::Display for TransactionModifier {
@@ -6407,6 +6424,8 @@ impl fmt::Display for TransactionModifier {
Deferred => "DEFERRED",
Immediate => "IMMEDIATE",
Exclusive => "EXCLUSIVE",
+ Try => "TRY",
+ Catch => "CATCH",
})
}
}
diff --git a/tmp/agent-patch-flux-pr-1649.1-of-1.2026-02-28__18-27-22__gpt-5-1-codex-mini/app/src/dialect/mssql.rs b/app/src/dialect/mssql.rs
index 2d0ef02..d6668d1 100644
--- a/tmp/agent-patch-flux-pr-1649.1-of-1.2026-02-28__18-27-22__gpt-5-1-codex-mini/app/src/dialect/mssql.rs
+++ b/app/src/dialect/mssql.rs
@@ -50,6 +50,10 @@ impl Dialect for MsSqlDialect {
true
}
+ fn supports_start_transaction_modifier(&self) -> bool {
+ true
+ }
+
fn supports_eq_alias_assignment(&self) -> bool {
true
}
diff --git a/tmp/agent-patch-flux-pr-1649.1-of-1.2026-02-28__18-27-22__gpt-5-1-codex-mini/app/src/keywords.rs b/app/src/keywords.rs
index c8f3cba..c50c2bd 100644
--- a/tmp/agent-patch-flux-pr-1649.1-of-1.2026-02-28__18-27-22__gpt-5-1-codex-mini/app/src/keywords.rs
+++ b/app/src/keywords.rs
@@ -151,6 +151,7 @@ define_keywords!(
CASE,
CAST,
CATALOG,
+ CATCH,
CEIL,
CEILING,
CENTURY,
@@ -812,6 +813,7 @@ define_keywords!(
TRIM_ARRAY,
TRUE,
TRUNCATE,
+ TRY,
TRY_CAST,
TRY_CONVERT,
TUPLE,
diff --git a/tmp/agent-patch-flux-pr-1649.1-of-1.2026-02-28__18-27-22__gpt-5-1-codex-mini/app/src/parser/mod.rs b/app/src/parser/mod.rs
index 95413a8..a9d06a2 100644
--- a/tmp/agent-patch-flux-pr-1649.1-of-1.2026-02-28__18-27-22__gpt-5-1-codex-mini/app/src/parser/mod.rs
+++ b/app/src/parser/mod.rs
@@ -12792,17 +12792,7 @@ impl<'a> Parser<'a> {
}
pub fn parse_begin(&mut self) -> Result<Statement, ParserError> {
- let modifier = if !self.dialect.supports_start_transaction_modifier() {
- None
- } else if self.parse_keyword(Keyword::DEFERRED) {
- Some(TransactionModifier::Deferred)
- } else if self.parse_keyword(Keyword::IMMEDIATE) {
- Some(TransactionModifier::Immediate)
- } else if self.parse_keyword(Keyword::EXCLUSIVE) {
- Some(TransactionModifier::Exclusive)
- } else {
- None
- };
+ let modifier = self.parse_transaction_modifier();
let transaction = match self.parse_one_of_keywords(&[Keyword::TRANSACTION, Keyword::WORK]) {
Some(Keyword::TRANSACTION) => Some(BeginTransactionKind::Transaction),
Some(Keyword::WORK) => Some(BeginTransactionKind::Work),
@@ -12816,8 +12806,28 @@ impl<'a> Parser<'a> {
})
}
+ fn parse_transaction_modifier(&mut self) -> Option<TransactionModifier> {
+ if !self.dialect.supports_start_transaction_modifier() {
+ return None;
+ }
+ if self.parse_keyword(Keyword::DEFERRED) {
+ Some(TransactionModifier::Deferred)
+ } else if self.parse_keyword(Keyword::IMMEDIATE) {
+ Some(TransactionModifier::Immediate)
+ } else if self.parse_keyword(Keyword::EXCLUSIVE) {
+ Some(TransactionModifier::Exclusive)
+ } else if self.parse_keyword(Keyword::TRY) {
+ Some(TransactionModifier::Try)
+ } else if self.parse_keyword(Keyword::CATCH) {
+ Some(TransactionModifier::Catch)
+ } else {
+ None
+ }
+ }
+
pub fn parse_end(&mut self) -> Result<Statement, ParserError> {
Ok(Statement::Commit {
+ modifier: self.parse_transaction_modifier(),
chain: self.parse_commit_rollback_chain()?,
})
}
@@ -12860,6 +12870,7 @@ impl<'a> Parser<'a> {
pub fn parse_commit(&mut self) -> Result<Statement, ParserError> {
Ok(Statement::Commit {
+ modifier: self.parse_transaction_modifier(),
chain: self.parse_commit_rollback_chain()?,
})
}
diff --git a/tmp/agent-patch-flux-pr-1649.1-of-1.2026-02-28__18-27-22__gpt-5-1-codex-mini/app/tests/sqlparser_common.rs b/app/tests/sqlparser_common.rs
index b47159d..550da06 100644
--- a/tmp/agent-patch-flux-pr-1649.1-of-1.2026-02-28__18-27-22__gpt-5-1-codex-mini/app/tests/sqlparser_common.rs
+++ b/app/tests/sqlparser_common.rs
@@ -8099,15 +8099,42 @@ fn parse_set_time_zone_alias() {
}
}
+#[test]
+fn parse_begin_try_catch() {
+ match verified_stmt("BEGIN TRY") {
+ Statement::StartTransaction {
+ begin: true,
+ modifier: Some(TransactionModifier::Try),
+ ..
+ } => (),
+ _ => unreachable!(),
+ }
+
+ match verified_stmt("BEGIN CATCH") {
+ Statement::StartTransaction {
+ begin: true,
+ modifier: Some(TransactionModifier::Catch),
+ ..
+ } => (),
+ _ => unreachable!(),
+ }
+}
+
#[test]
fn parse_commit() {
match verified_stmt("COMMIT") {
- Statement::Commit { chain: false } => (),
+ Statement::Commit {
+ chain: false,
+ modifier: None,
+ } => (),
_ => unreachable!(),
}
match verified_stmt("COMMIT AND CHAIN") {
- Statement::Commit { chain: true } => (),
+ Statement::Commit {
+ chain: true,
+ modifier: None,
+ } => (),
_ => unreachable!(),
}
@@ -8131,6 +8158,26 @@ fn parse_end() {
one_statement_parses_to("END TRANSACTION", "COMMIT");
}
+#[test]
+fn parse_end_try_catch() {
+ match verified_stmt("END TRY") {
+ Statement::Commit {
+ chain: false,
+ modifier: Some(TransactionModifier::Try),
+ } => (),
+ _ => unreachable!(),
+ }
+
+ match verified_stmt("END CATCH") {
+ Statement::Commit {
+ chain: false,
+ modifier: Some(TransactionModifier::Catch),
+ } => (),
+ _ => unreachable!(),
+ }
+}
+
+
#[test]
fn parse_rollback() {
match verified_stmt("ROLLBACK") {
diff --git a/tmp/agent-patch-flux-pr-1649.1-of-1.2026-02-28__18-27-22__gpt-5-1-codex-mini/app/tests/sqlparser_custom_dialect.rs b/app/tests/sqlparser_custom_dialect.rs
index e9ca82a..5ee6282 100644
--- a/tmp/agent-patch-flux-pr-1649.1-of-1.2026-02-28__18-27-22__gpt-5-1-codex-mini/app/tests/sqlparser_custom_dialect.rs
+++ b/app/tests/sqlparser_custom_dialect.rs
@@ -115,7 +115,10 @@ fn custom_statement_parser() -> Result<(), ParserError> {
for _ in 0..3 {
let _ = parser.next_token();
}
- Some(Ok(Statement::Commit { chain: false }))
+ Some(Ok(Statement::Commit {
+ chain: false,
+ modifier: None,
+ }))
} else {
None
}