Struct FrankenConnection 

pub struct FrankenConnection { /* private fields */ }

A SQLite connection backed by FrankenSQLite (pure Rust).

Implements sqlmodel_core::Connection and provides sync helper methods (execute_raw, query_sync, execute_sync, etc.) matching the SqliteConnection API for drop-in replacement.

Implementations

impl FrankenConnection

pub fn open(path: impl Into<String>) -> Result<Self, Error>

Open a connection with the given path.

Use ":memory:" for an in-memory database, or a file path for persistent storage.

pub fn open_memory() -> Result<Self, Error>

Open an in-memory database.

pub fn open_file(path: impl Into<String>) -> Result<Self, Error>

Open a file-based database.

pub fn path(&self) -> &str

Get the database path.

pub fn close_sync(self) -> Result<(), Error>

Close the underlying frankensqlite connection synchronously.

pub fn execute_raw(&self, sql: &str) -> Result<(), Error>

Execute SQL directly without parameter binding (for DDL, PRAGMAs, etc.)

pub fn query_sync(&self, sql: &str, params: &[Value]) -> Result<Vec<Row>, Error>

Prepare and execute a query synchronously, returning all rows.

pub fn execute_sync(&self, sql: &str, params: &[Value]) -> Result<u64, Error>

Prepare and execute a statement synchronously, returning rows affected.

pub fn last_insert_rowid(&self) -> i64

Get the last inserted rowid.

pub fn changes(&self) -> i64

Get the number of rows changed by the last statement.

Trait Implementations

impl Connection for FrankenConnection

type Tx<'conn> = FrankenTransaction<'conn> where Self: 'conn

The transaction type returned by this connection.

fn dialect(&self) -> Dialect

Get the SQL dialect for this connection.

fn query( &self, _cx: &Cx, sql: &str, params: &[Value], ) -> impl Future<Output = Outcome<Vec<Row>, Error>> + Send

Execute a query and return all rows.

fn query_one( &self, _cx: &Cx, sql: &str, params: &[Value], ) -> impl Future<Output = Outcome<Option<Row>, Error>> + Send

Execute a query and return the first row, if any.

fn execute( &self, _cx: &Cx, sql: &str, params: &[Value], ) -> impl Future<Output = Outcome<u64, Error>> + Send

Execute a statement (INSERT, UPDATE, DELETE) and return rows affected.

fn insert( &self, _cx: &Cx, sql: &str, params: &[Value], ) -> impl Future<Output = Outcome<i64, Error>> + Send

Execute an INSERT and return the last inserted ID.

fn batch( &self, _cx: &Cx, statements: &[(String, Vec<Value>)], ) -> impl Future<Output = Outcome<Vec<u64>, Error>> + Send

Execute multiple statements in a batch.

fn begin( &self, cx: &Cx, ) -> impl Future<Output = Outcome<Self::Tx<'_>, Error>> + Send

Begin a transaction with default isolation level (ReadCommitted).

fn begin_with( &self, _cx: &Cx, isolation: IsolationLevel, ) -> impl Future<Output = Outcome<Self::Tx<'_>, Error>> + Send

Begin a transaction with a specific isolation level.

fn prepare( &self, _cx: &Cx, sql: &str, ) -> impl Future<Output = Outcome<PreparedStatement, Error>> + Send

Prepare a statement for repeated execution.

fn query_prepared( &self, cx: &Cx, stmt: &PreparedStatement, params: &[Value], ) -> impl Future<Output = Outcome<Vec<Row>, Error>> + Send

Execute a prepared statement and return all rows.

fn execute_prepared( &self, cx: &Cx, stmt: &PreparedStatement, params: &[Value], ) -> impl Future<Output = Outcome<u64, Error>> + Send

Execute a prepared statement (INSERT, UPDATE, DELETE) and return rows affected.

fn ping(&self, _cx: &Cx) -> impl Future<Output = Outcome<(), Error>> + Send

Check if the connection is still valid by sending a ping.

async fn close(self, _cx: &Cx) -> Result<()>

Close the connection gracefully.

fn is_valid(&self, cx: &Cx) -> impl Future<Output = bool> + Send

Check if the connection is still valid (alias for ping that returns bool).

impl Send for FrankenConnection

impl Sync for FrankenConnection