1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156
use crate::{
execute::{execute_columns, execute_tables, execute_with_parameters},
handles::{SqlText, StatementImpl},
CursorImpl, Error, ParameterRefCollection,
};
/// A preallocated SQL statement handle intended for sequential execution of different queries. See
/// [`crate::Connection::preallocate`].
///
/// # Example
///
/// ```
/// use odbc_api::{Connection, Error};
/// use std::io::{self, stdin, Read};
///
/// fn interactive(conn: &Connection) -> io::Result<()>{
/// let mut statement = conn.preallocate().unwrap();
/// let mut query = String::new();
/// stdin().read_line(&mut query)?;
/// while !query.is_empty() {
/// match statement.execute(&query, ()) {
/// Err(e) => println!("{}", e),
/// Ok(None) => println!("No results set generated."),
/// Ok(Some(cursor)) => {
/// // ...print cursor contents...
/// },
/// }
/// stdin().read_line(&mut query)?;
/// }
/// Ok(())
/// }
/// ```
pub struct Preallocated<'open_connection> {
statement: StatementImpl<'open_connection>,
}
impl<'o> Preallocated<'o> {
pub(crate) fn new(statement: StatementImpl<'o>) -> Self {
Self { statement }
}
/// Executes a statement. This is the fastest way to sequentially execute different SQL
/// Statements.
///
/// # Parameters
///
/// * `query`: The text representation of the SQL statement. E.g. "SELECT * FROM my_table;".
/// * `params`: `?` may be used as a placeholder in the statement text. You can use `()` to
/// represent no parameters. Check the [`crate::parameter`] module level documentation for
/// more information on how to pass parameters.
///
/// # Return
///
/// Returns `Some` if a cursor is created. If `None` is returned no cursor has been created (
/// e.g. the query came back empty). Note that an empty query may also create a cursor with zero
/// rows. Since we want to reuse the statement handle a returned cursor will not take ownership
/// of it and instead burrow it.
///
/// # Example
///
/// ```
/// use odbc_api::{Connection, Error};
/// use std::io::{self, stdin, Read};
///
/// fn interactive(conn: &Connection) -> io::Result<()>{
/// let mut statement = conn.preallocate().unwrap();
/// let mut query = String::new();
/// stdin().read_line(&mut query)?;
/// while !query.is_empty() {
/// match statement.execute(&query, ()) {
/// Err(e) => println!("{}", e),
/// Ok(None) => println!("No results set generated."),
/// Ok(Some(cursor)) => {
/// // ...print cursor contents...
/// },
/// }
/// stdin().read_line(&mut query)?;
/// }
/// Ok(())
/// }
/// ```
pub fn execute(
&mut self,
query: &str,
params: impl ParameterRefCollection,
) -> Result<Option<CursorImpl<&mut StatementImpl<'o>>>, Error> {
let query = SqlText::new(query);
execute_with_parameters(move || Ok(&mut self.statement), Some(&query), params)
}
/// Transfer ownership to the underlying statement handle.
///
/// The resulting type is one level of indirection away from the raw pointer of the ODBC API. It
/// no longer has any guarantees about bound buffers, but is still guaranteed to be a valid
/// allocated statement handle. This serves together with
/// [`crate::handles::StatementImpl::into_sys`] or [`crate::handles::Statement::as_sys`] this
/// serves as an escape hatch to access the functionality provided by `crate::sys` not yet
/// accessible through safe abstractions.
pub fn into_statement(self) -> StatementImpl<'o> {
self.statement
}
/// List tables, schemas, views and catalogs of a datasource.
///
/// # Parameters
///
/// * `catalog_name`: Filter result by catalog name. Accept search patterns. Use `%` to match
/// any number of characters. Use `_` to match exactly on character. Use `\` to escape
/// characeters.
/// * `schema_name`: Filter result by schema. Accepts patterns in the same way as
/// `catalog_name`.
/// * `table_name`: Filter result by table. Accepts patterns in the same way as `catalog_name`.
/// * `table_type`: Filters results by table type. E.g: 'TABLE', 'VIEW'. This argument accepts a
/// comma separeted list of table types. Omit it to not filter the result by table type at
/// all.
pub fn tables(
&mut self,
catalog_name: &str,
schema_name: &str,
table_name: &str,
table_type: &str,
) -> Result<CursorImpl<&mut StatementImpl<'o>>, Error> {
execute_tables(
&mut self.statement,
&SqlText::new(catalog_name),
&SqlText::new(schema_name),
&SqlText::new(table_name),
&SqlText::new(table_type),
)
}
/// A cursor describing columns of all tables matching the patterns. Patterns support as
/// placeholder `%` for multiple characters or `_` for a single character. Use `\` to escape.The
/// returned cursor has the columns:
/// `TABLE_CAT`, `TABLE_SCHEM`, `TABLE_NAME`, `COLUMN_NAME`, `DATA_TYPE`, `TYPE_NAME`,
/// `COLUMN_SIZE`, `BUFFER_LENGTH`, `DECIMAL_DIGITS`, `NUM_PREC_RADIX`, `NULLABLE`,
/// `REMARKS`, `COLUMN_DEF`, `SQL_DATA_TYPE`, `SQL_DATETIME_SUB`, `CHAR_OCTET_LENGTH`,
/// `ORDINAL_POSITION`, `IS_NULLABLE`.
///
/// In addition to that there may be a number of columns specific to the data source.
pub fn columns(
&mut self,
catalog_name: &str,
schema_name: &str,
table_name: &str,
column_name: &str,
) -> Result<CursorImpl<&mut StatementImpl<'o>>, Error> {
execute_columns(
&mut self.statement,
&SqlText::new(catalog_name),
&SqlText::new(schema_name),
&SqlText::new(table_name),
&SqlText::new(column_name),
)
}
}