Struct SqlExecutor 

pub struct SqlExecutor;

Implementations

impl SqlExecutor

pub async fn execute_statements(db: &Database, sql: &str) -> DatabaseResult<()>

pub async fn execute_statements_parsed( db: &dyn DatabaseProvider, sql: &str, ) -> DatabaseResult<()>

pub fn parse_sql_statements(sql: &str) -> DatabaseResult<Vec<String>>

Split a Postgres SQL script into individual statements while preserving the original source text. Splits on top-level ;; ignores semicolons inside single quotes, dollar-quoted bodies ($$ … $$ and $tag$ … $tag$), -- line comments, and /* … */ block comments (nested). Unterminated quotes or comments return RepositoryError::Internal; grammar errors are left for Postgres to surface at execute time. Preserving the original text is the reason this is hand-rolled rather than sqlparser: round-tripping through Statement::Display drops syntactic detail such as the empty parameter list on CREATE FUNCTION foo(), which Postgres then rejects.

pub async fn execute_query( db: &Database, query: &str, ) -> DatabaseResult<QueryResult>

pub async fn execute_file(db: &Database, file_path: &str) -> DatabaseResult<()>

pub async fn execute_file_parsed( db: &dyn DatabaseProvider, file_path: &str, ) -> DatabaseResult<()>

pub async fn table_exists( db: &Database, table_name: &str, ) -> DatabaseResult<bool>

pub async fn column_exists( db: &Database, table_name: &str, column_name: &str, ) -> DatabaseResult<bool>

Trait Implementations

impl Clone for SqlExecutor

fn clone(&self) -> SqlExecutor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SqlExecutor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Copy for SqlExecutor