mirror of
https://github.com/launchbadge/sqlx.git
synced 2025-10-04 08:15:39 +00:00
style: rustfmt
This commit is contained in:
parent
89305873b0
commit
df393128f8
@ -1,5 +1,7 @@
|
|||||||
use crate::any::connection::AnyConnectionKind;
|
use crate::any::connection::AnyConnectionKind;
|
||||||
use crate::any::{Any, AnyColumn, AnyConnection, AnyQueryResult, AnyRow, AnyStatement, AnyTypeInfo};
|
use crate::any::{
|
||||||
|
Any, AnyColumn, AnyConnection, AnyQueryResult, AnyRow, AnyStatement, AnyTypeInfo,
|
||||||
|
};
|
||||||
use crate::database::Database;
|
use crate::database::Database;
|
||||||
use crate::describe::Describe;
|
use crate::describe::Describe;
|
||||||
use crate::error::Error;
|
use crate::error::Error;
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
use crate::any::{
|
use crate::any::{
|
||||||
AnyArgumentBuffer, AnyArguments, AnyColumn, AnyConnection, AnyQueryResult, AnyRow, AnyStatement,
|
AnyArgumentBuffer, AnyArguments, AnyColumn, AnyConnection, AnyQueryResult, AnyRow,
|
||||||
AnyTransactionManager, AnyTypeInfo, AnyValue, AnyValueRef,
|
AnyStatement, AnyTransactionManager, AnyTypeInfo, AnyValue, AnyValueRef,
|
||||||
};
|
};
|
||||||
use crate::database::{Database, HasArguments, HasStatement, HasStatementCache, HasValueRef};
|
use crate::database::{Database, HasArguments, HasStatement, HasStatementCache, HasValueRef};
|
||||||
|
|
||||||
|
@ -10,7 +10,8 @@ use crate::mssql::protocol::packet::PacketType;
|
|||||||
use crate::mssql::protocol::rpc::{OptionFlags, Procedure, RpcRequest};
|
use crate::mssql::protocol::rpc::{OptionFlags, Procedure, RpcRequest};
|
||||||
use crate::mssql::protocol::sql_batch::SqlBatch;
|
use crate::mssql::protocol::sql_batch::SqlBatch;
|
||||||
use crate::mssql::{
|
use crate::mssql::{
|
||||||
Mssql, MssqlArguments, MssqlConnection, MssqlQueryResult, MssqlRow, MssqlStatement, MssqlTypeInfo,
|
Mssql, MssqlArguments, MssqlConnection, MssqlQueryResult, MssqlRow, MssqlStatement,
|
||||||
|
MssqlTypeInfo,
|
||||||
};
|
};
|
||||||
use either::Either;
|
use either::Either;
|
||||||
use futures_core::future::BoxFuture;
|
use futures_core::future::BoxFuture;
|
||||||
|
@ -7,8 +7,8 @@ mod database;
|
|||||||
mod error;
|
mod error;
|
||||||
mod io;
|
mod io;
|
||||||
mod options;
|
mod options;
|
||||||
mod query_result;
|
|
||||||
mod protocol;
|
mod protocol;
|
||||||
|
mod query_result;
|
||||||
mod row;
|
mod row;
|
||||||
mod statement;
|
mod statement;
|
||||||
mod transaction;
|
mod transaction;
|
||||||
|
@ -88,7 +88,8 @@ impl MySqlConnection {
|
|||||||
sql: &'q str,
|
sql: &'q str,
|
||||||
arguments: Option<MySqlArguments>,
|
arguments: Option<MySqlArguments>,
|
||||||
persistent: bool,
|
persistent: bool,
|
||||||
) -> Result<impl Stream<Item = Result<Either<MySqlQueryResult, MySqlRow>, Error>> + 'e, Error> {
|
) -> Result<impl Stream<Item = Result<Either<MySqlQueryResult, MySqlRow>, Error>> + 'e, Error>
|
||||||
|
{
|
||||||
let mut logger = QueryLogger::new(sql, self.log_settings.clone());
|
let mut logger = QueryLogger::new(sql, self.log_settings.clone());
|
||||||
|
|
||||||
self.stream.wait_until_ready().await?;
|
self.stream.wait_until_ready().await?;
|
||||||
|
@ -8,8 +8,8 @@ mod database;
|
|||||||
mod error;
|
mod error;
|
||||||
mod io;
|
mod io;
|
||||||
mod options;
|
mod options;
|
||||||
mod query_result;
|
|
||||||
mod protocol;
|
mod protocol;
|
||||||
|
mod query_result;
|
||||||
mod row;
|
mod row;
|
||||||
mod statement;
|
mod statement;
|
||||||
mod transaction;
|
mod transaction;
|
||||||
|
@ -6,8 +6,8 @@ use crate::postgres::type_info::{PgCustomType, PgType, PgTypeKind};
|
|||||||
use crate::postgres::{PgArguments, PgColumn, PgConnection, PgTypeInfo};
|
use crate::postgres::{PgArguments, PgColumn, PgConnection, PgTypeInfo};
|
||||||
use crate::query_as::query_as;
|
use crate::query_as::query_as;
|
||||||
use crate::query_scalar::{query_scalar, query_scalar_with};
|
use crate::query_scalar::{query_scalar, query_scalar_with};
|
||||||
use crate::HashMap;
|
|
||||||
use crate::types::Json;
|
use crate::types::Json;
|
||||||
|
use crate::HashMap;
|
||||||
use futures_core::future::BoxFuture;
|
use futures_core::future::BoxFuture;
|
||||||
use std::fmt::Write;
|
use std::fmt::Write;
|
||||||
use std::sync::Arc;
|
use std::sync::Arc;
|
||||||
|
@ -9,8 +9,8 @@ use crate::postgres::message::{
|
|||||||
use crate::postgres::statement::PgStatementMetadata;
|
use crate::postgres::statement::PgStatementMetadata;
|
||||||
use crate::postgres::type_info::PgType;
|
use crate::postgres::type_info::PgType;
|
||||||
use crate::postgres::{
|
use crate::postgres::{
|
||||||
statement::PgStatement, PgArguments, PgConnection, PgQueryResult, PgRow, PgTypeInfo, PgValueFormat,
|
statement::PgStatement, PgArguments, PgConnection, PgQueryResult, PgRow, PgTypeInfo,
|
||||||
Postgres,
|
PgValueFormat, Postgres,
|
||||||
};
|
};
|
||||||
use either::Either;
|
use either::Either;
|
||||||
use futures_core::future::BoxFuture;
|
use futures_core::future::BoxFuture;
|
||||||
|
@ -1,7 +1,8 @@
|
|||||||
use crate::database::{Database, HasArguments, HasStatement, HasStatementCache, HasValueRef};
|
use crate::database::{Database, HasArguments, HasStatement, HasStatementCache, HasValueRef};
|
||||||
use crate::sqlite::{
|
use crate::sqlite::{
|
||||||
SqliteArgumentValue, SqliteArguments, SqliteColumn, SqliteConnection, SqliteQueryResult, SqliteRow,
|
SqliteArgumentValue, SqliteArguments, SqliteColumn, SqliteConnection, SqliteQueryResult,
|
||||||
SqliteStatement, SqliteTransactionManager, SqliteTypeInfo, SqliteValue, SqliteValueRef,
|
SqliteRow, SqliteStatement, SqliteTransactionManager, SqliteTypeInfo, SqliteValue,
|
||||||
|
SqliteValueRef,
|
||||||
};
|
};
|
||||||
|
|
||||||
/// Sqlite database driver.
|
/// Sqlite database driver.
|
||||||
|
Loading…
x
Reference in New Issue
Block a user