Struct Tx

internal/database/db.go:255–267

Tx wraps sql.Tx to provide prepared statement caching for transaction queries

// Tx wraps sql.Tx to provide prepared statement caching for transaction queries
type Tx struct {
	tx         *sql.Tx
	db         *DB
	ctx        context.Context // context from BeginTx, used for commit/rollback
	isWriteTx  bool            // true if this is a write transaction that needs serialized commit
	unlockFn   func()          // function to unlock writerMu when transaction completes (write tx only)
	unlockOnce sync.Once       // ensures unlock happens only once

	// Track statements prepared during this transaction for promotion to DB cache after commit
	txStmts    map[string]struct{} // query -> struct{} (used as set to track which queries to cache)
	tempTables map[string]struct{} // temp table names created/used in this transaction
	txMu       sync.Mutex          // protects transaction-local cache metadata
}

// markQueryForCaching records a successfully executed query for post-commit
// statement promotion and tracks temp-table lifecycle within the transaction.