Mirrors/sqlx
2
0
Fork 0
mirror of https://github.com/launchbadge/sqlx synced 2024-11-10 06:24:16 +00:00
Code Issues Projects Releases Packages Wiki Activity

fix: clippy warnings

Browse source
This commit is contained in:
Austin Bonander 2024-06-05 20:15:44 -07:00
parent 41089f3655
commit bae083cf79
110 changed files with 513 additions and 480 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
.github/workflows/sqlx.yml vendored
View file

@ -34,6 +34,7 @@ jobs:
rustup update
rustup component add clippy
rustup toolchain install beta
rustup component add --toolchain beta clippy
- run: >
cargo clippy

18
clippy.toml
View file

@ -1,5 +1,13 @@
disallowed-methods = [
# It is *much* too easy to misread `x.min(y)` as "x should be *at least* y" when in fact it
# means the *exact* opposite, and same with `x.max(y)`; use `cmp::{min, max}` instead.
"core::cmp::Ord::min", "core::cmp::Ord::max"
]
[[disallowed-methods]]
path = "core::cmp::Ord::min"
reason = '''
too easy to misread `x.min(y)` as "let the minimum value of `x` be `y`" when it actually means the exact opposite;
use `std::cmp::min` instead.
'''
[[disallowed-methods]]
path = "core::cmp::Ord::max"
reason = '''
too easy to misread `x.max(y)` as "let the maximum value of `x` be `y`" when it actually means the exact opposite;
use `std::cmp::max` instead.
'''

7
sqlx-cli/src/lib.rs
View file

@ -129,16 +129,15 @@ where
.build(),
|| {
connect(db_url).map_err(|e| -> backoff::Error<anyhow::Error> {
match e {
sqlx::Error::Io(ref ioe) => match ioe.kind() {
if let sqlx::Error::Io(ref ioe) = e {
match ioe.kind() {
io::ErrorKind::ConnectionRefused
| io::ErrorKind::ConnectionReset
| io::ErrorKind::ConnectionAborted => {
return backoff::Error::transient(e.into());
}
_ => (),
},
_ => (),
}
}
backoff::Error::permanent(e.into())

2
sqlx-cli/src/metadata.rs
View file

@ -83,7 +83,7 @@ impl Metadata {
self.packages.get(id)
}
pub fn entries<'this>(&'this self) -> btree_map::Iter<'this, MetadataId, Package> {
pub fn entries(&self) -> btree_map::Iter<'_, MetadataId, Package> {
self.packages.iter()
}

31
sqlx-cli/src/migrate.rs
View file

@ -20,7 +20,7 @@ fn create_file(
use std::path::PathBuf;
let mut file_name = file_prefix.to_string();
file_name.push_str("_");
file_name.push('_');
file_name.push_str(&description.replace(' ', "_"));
file_name.push_str(migration_type.suffix());
@ -120,20 +120,20 @@ pub async fn add(
if migration_type.is_reversible() {
create_file(
migration_source,
&file_prefix,
file_prefix,
description,
MigrationType::ReversibleUp,
)?;
create_file(
migration_source,
&file_prefix,
file_prefix,
description,
MigrationType::ReversibleDown,
)?;
} else {
create_file(
migration_source,
&file_prefix,
file_prefix,
description,
MigrationType::Simple,
)?;
@ -194,7 +194,7 @@ fn short_checksum(checksum: &[u8]) -> String {
pub async fn info(migration_source: &str, connect_opts: &ConnectOpts) -> anyhow::Result<()> {
let migrator = Migrator::new(Path::new(migration_source)).await?;
let mut conn = crate::connect(&connect_opts).await?;
let mut conn = crate::connect(connect_opts).await?;
conn.ensure_migrations_table().await?;
@ -300,7 +300,7 @@ pub async fn run(
let latest_version = applied_migrations
.iter()
.max_by(|x, y| x.version.cmp(&y.version))
.and_then(|migration| Some(migration.version))
.map(|migration| migration.version)
.unwrap_or(0);
if let Some(target_version) = target_version {
if target_version < latest_version {
@ -326,10 +326,8 @@ pub async fn run(
}
}
None => {
let skip = match target_version {
Some(target_version) if migration.version > target_version => true,
_ => false,
};
let skip =
target_version.is_some_and(|target_version| migration.version > target_version);
let elapsed = if dry_run || skip {
Duration::new(0, 0)
@ -380,7 +378,7 @@ pub async fn revert(
}
}
let mut conn = crate::connect(&connect_opts).await?;
let mut conn = crate::connect(connect_opts).await?;
conn.ensure_migrations_table().await?;
@ -395,7 +393,7 @@ pub async fn revert(
let latest_version = applied_migrations
.iter()
.max_by(|x, y| x.version.cmp(&y.version))
.and_then(|migration| Some(migration.version))
.map(|migration| migration.version)
.unwrap_or(0);
if let Some(target_version) = target_version {
if target_version > latest_version {
@ -417,10 +415,9 @@ pub async fn revert(
}
if applied_migrations.contains_key(&migration.version) {
let skip = match target_version {
Some(target_version) if migration.version <= target_version => true,
_ => false,
};
let skip =
target_version.is_some_and(|target_version| migration.version <= target_version);
let elapsed = if dry_run || skip {
Duration::new(0, 0)
} else {
@ -447,7 +444,7 @@ pub async fn revert(
// Only a single migration will be reverted at a time if no target
// version is supplied, so we break.
if let None = target_version {
if target_version.is_none() {
break;
}
}

8
sqlx-core/src/any/connection/executor.rs
View file

@ -11,13 +11,13 @@ use std::future;
impl<'c> Executor<'c> for &'c mut AnyConnection {
type Database = Any;
fn fetch_many<'e, 'q: 'e, E: 'q>(
fn fetch_many<'e, 'q: 'e, E>(
self,
mut query: E,
) -> BoxStream<'e, Result<Either<AnyQueryResult, AnyRow>, Error>>
where
'c: 'e,
E: Execute<'q, Any>,
E: 'q + Execute<'q, Any>,
{
let arguments = match query.take_arguments().map_err(Error::Encode) {
Ok(arguments) => arguments,
@ -26,13 +26,13 @@ impl<'c> Executor<'c> for &'c mut AnyConnection {
self.backend.fetch_many(query.sql(), arguments)
}
fn fetch_optional<'e, 'q: 'e, E: 'q>(
fn fetch_optional<'e, 'q: 'e, E>(
self,
mut query: E,
) -> BoxFuture<'e, Result<Option<AnyRow>, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>,
E: 'q + Execute<'q, Self::Database>,
{
let arguments = match query.take_arguments().map_err(Error::Encode) {
Ok(arguments) => arguments,

4
sqlx-core/src/any/statement.rs
View file

@ -38,7 +38,7 @@ impl<'q> Statement<'q> for AnyStatement<'q> {
fn parameters(&self) -> Option<Either<&[AnyTypeInfo], usize>> {
match &self.parameters {
Some(Either::Left(types)) => Some(Either::Left(&types)),
Some(Either::Left(types)) => Some(Either::Left(types)),
Some(Either::Right(count)) => Some(Either::Right(*count)),
None => None,
}
@ -57,7 +57,7 @@ impl<'i> ColumnIndex<AnyStatement<'_>> for &'i str {
.column_names
.get(*self)
.ok_or_else(|| Error::ColumnNotFound((*self).into()))
.map(|v| *v)
.copied()
}
}

2
sqlx-core/src/arguments.rs
View file

@ -7,6 +7,8 @@ use crate::types::Type;
use std::fmt::{self, Write};
/// A tuple of arguments to be sent to the database.
// This lint is designed for general collections, but `Arguments` is not meant to be as such.
#[allow(clippy::len_without_is_empty)]
pub trait Arguments<'q>: Send + Sized + Default {
type Database: Database;

4
sqlx-core/src/common/statement_cache.rs
View file

@ -43,6 +43,10 @@ impl<T> StatementCache<T> {
self.inner.len()
}
pub fn is_empty(&self) -> bool {
self.inner.is_empty()
}
/// Removes the least recently used item from the cache.
pub fn remove_lru(&mut self) -> Option<T> {
self.inner.remove_lru().map(|(_, v)| v)

2
sqlx-core/src/connection.rs
View file

@ -143,7 +143,7 @@ pub trait Connection: Send {
{
let options = url.parse();
Box::pin(async move { Ok(Self::connect_with(&options?).await?) })
Box::pin(async move { Self::connect_with(&options?).await })
}
/// Establish a new database connection with the provided options.

28
sqlx-core/src/executor.rs
View file

@ -34,25 +34,25 @@ pub trait Executor<'c>: Send + Debug + Sized {
type Database: Database;
/// Execute the query and return the total number of rows affected.
fn execute<'e, 'q: 'e, E: 'q>(
fn execute<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxFuture<'e, Result<<Self::Database as Database>::QueryResult, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>,
E: 'q + Execute<'q, Self::Database>,
{
self.execute_many(query).try_collect().boxed()
}
/// Execute multiple queries and return the rows affected from each query, in a stream.
fn execute_many<'e, 'q: 'e, E: 'q>(
fn execute_many<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxStream<'e, Result<<Self::Database as Database>::QueryResult, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>,
E: 'q + Execute<'q, Self::Database>,
{
self.fetch_many(query)
.try_filter_map(|step| async move {
@ -65,13 +65,13 @@ pub trait Executor<'c>: Send + Debug + Sized {
}
/// Execute the query and return the generated results as a stream.
fn fetch<'e, 'q: 'e, E: 'q>(
fn fetch<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxStream<'e, Result<<Self::Database as Database>::Row, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>,
E: 'q + Execute<'q, Self::Database>,
{
self.fetch_many(query)
.try_filter_map(|step| async move {
@ -85,7 +85,7 @@ pub trait Executor<'c>: Send + Debug + Sized {
/// Execute multiple queries and return the generated results as a stream
/// from each query, in a stream.
fn fetch_many<'e, 'q: 'e, E: 'q>(
fn fetch_many<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxStream<
@ -97,28 +97,28 @@ pub trait Executor<'c>: Send + Debug + Sized {
>
where
'c: 'e,
E: Execute<'q, Self::Database>;
E: 'q + Execute<'q, Self::Database>;
/// Execute the query and return all the generated results, collected into a [`Vec`].
fn fetch_all<'e, 'q: 'e, E: 'q>(
fn fetch_all<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxFuture<'e, Result<Vec<<Self::Database as Database>::Row>, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>,
E: 'q + Execute<'q, Self::Database>,
{
self.fetch(query).try_collect().boxed()
}
/// Execute the query and returns exactly one row.
fn fetch_one<'e, 'q: 'e, E: 'q>(
fn fetch_one<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxFuture<'e, Result<<Self::Database as Database>::Row, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>,
E: 'q + Execute<'q, Self::Database>,
{
self.fetch_optional(query)
.and_then(|row| match row {
@ -129,13 +129,13 @@ pub trait Executor<'c>: Send + Debug + Sized {
}
/// Execute the query and returns at most one row.
fn fetch_optional<'e, 'q: 'e, E: 'q>(
fn fetch_optional<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxFuture<'e, Result<Option<<Self::Database as Database>::Row>, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>;
E: 'q + Execute<'q, Self::Database>;
/// Prepare the SQL query to inspect the type information of its parameters
/// and results.

4
sqlx-core/src/ext/async_stream.rs
View file

@ -121,10 +121,10 @@ impl<'a, T> Stream for TryAsyncStream<'a, T> {
#[macro_export]
macro_rules! try_stream {
($($block:tt)*) => {
crate::ext::async_stream::TryAsyncStream::new(move |yielder| async move {
$crate::ext::async_stream::TryAsyncStream::new(move |yielder| async move {
// Anti-footgun: effectively pins `yielder` to this future to prevent any accidental
// move to another task, which could deadlock.
let ref yielder = yielder;
let yielder = &yielder;
macro_rules! r#yield {
($v:expr) => {{

6
sqlx-core/src/ext/ustr.rs
View file

@ -36,14 +36,14 @@ impl Hash for UStr {
fn hash<H: Hasher>(&self, state: &mut H) {
// Forward the hash to the string representation of this
// A derive(Hash) encodes the enum discriminant
(&**self).hash(state);
(**self).hash(state);
}
}
impl Borrow<str> for UStr {
#[inline]
fn borrow(&self) -> &str {
&**self
self
}
}
@ -102,6 +102,6 @@ impl serde::Serialize for UStr {
where
S: serde::Serializer,
{
serializer.serialize_str(&self)
serializer.serialize_str(self)
}
}

4
sqlx-core/src/io/buf.rs
View file

@ -22,7 +22,7 @@ pub trait BufExt: Buf {
impl BufExt for Bytes {
fn get_bytes_nul(&mut self) -> Result<Bytes, Error> {
let nul =
memchr(b'\0', &self).ok_or_else(|| err_protocol!("expected NUL in byte sequence"))?;
memchr(b'\0', self).ok_or_else(|| err_protocol!("expected NUL in byte sequence"))?;
let v = self.slice(0..nul);
@ -40,7 +40,7 @@ impl BufExt for Bytes {
fn get_str_nul(&mut self) -> Result<String, Error> {
self.get_bytes_nul().and_then(|bytes| {
from_utf8(&*bytes)
from_utf8(&bytes)
.map(ToOwned::to_owned)
.map_err(|err| err_protocol!("{}", err))
})

2
sqlx-core/src/lib.rs
View file

@ -16,7 +16,7 @@
#![warn(future_incompatible, rust_2018_idioms)]
#![allow(clippy::needless_doctest_main, clippy::type_complexity)]
// See `clippy.toml` at the workspace root
#![deny(clippy::disallowed_method)]
#![deny(clippy::disallowed_methods)]
// The only unsafe code in SQLx is that necessary to interact with native APIs like with SQLite,
// and that can live in its own separate driver crate.
#![forbid(unsafe_code)]

4
sqlx-core/src/logger.rs
View file

@ -106,14 +106,14 @@ impl<'q> QueryLogger<'q> {
let log_is_enabled = log::log_enabled!(target: "sqlx::query", log_level)
|| private_tracing_dynamic_enabled!(target: "sqlx::query", tracing_level);
if log_is_enabled {
let mut summary = parse_query_summary(&self.sql);
let mut summary = parse_query_summary(self.sql);
let sql = if summary != self.sql {
summary.push_str(" …");
format!(
"\n\n{}\n",
sqlformat::format(
&self.sql,
self.sql,
&sqlformat::QueryParams::None,
sqlformat::FormatOptions::default()
)

4
sqlx-core/src/migrate/source.rs
View file

@ -55,14 +55,14 @@ pub struct ResolveError {
// FIXME: paths should just be part of `Migration` but we can't add a field backwards compatibly
// since it's `#[non_exhaustive]`.
pub fn resolve_blocking(path: &Path) -> Result<Vec<(Migration, PathBuf)>, ResolveError> {
let mut s = fs::read_dir(path).map_err(|e| ResolveError {
let s = fs::read_dir(path).map_err(|e| ResolveError {
message: format!("error reading migration directory {}: {e}", path.display()),
source: Some(e),
})?;
let mut migrations = Vec::new();
while let Some(res) = s.next() {
for res in s {
let entry = res.map_err(|e| ResolveError {
message: format!(
"error reading contents of migration directory {}: {e}",

41
sqlx-core/src/net/socket/mod.rs
View file

@ -101,7 +101,7 @@ where
let this = &mut *self;
while !this.buf.is_empty() {
match this.socket.try_write(&mut this.buf) {
match this.socket.try_write(this.buf) {
Err(e) if e.kind() == io::ErrorKind::WouldBlock => {
ready!(this.socket.poll_write_ready(cx))?;
}
@ -225,14 +225,12 @@ pub async fn connect_tcp<Ws: WithSocket>(
// If we reach this point, it means we failed to connect to any of the addresses.
// Return the last error we encountered, or a custom error if the hostname didn't resolve to any address.
match last_err {
Some(err) => return Err(err.into()),
None => {
return Err(io::Error::new(
Some(err) => Err(err.into()),
None => Err(io::Error::new(
io::ErrorKind::AddrNotAvailable,
"Hostname did not resolve to any addresses",
)
.into())
}
.into()),
}
}
@ -249,18 +247,9 @@ pub async fn connect_uds<P: AsRef<Path>, Ws: WithSocket>(
path: P,
with_socket: Ws,
) -> crate::Result<Ws::Output> {
#[cfg(not(unix))]
#[cfg(unix)]
{
drop((path, with_socket));
return Err(io::Error::new(
io::ErrorKind::Unsupported,
"Unix domain sockets are not supported on this platform",
)
.into());
}
#[cfg(all(unix, feature = "_rt-tokio"))]
#[cfg(feature = "_rt-tokio")]
if crate::rt::rt_tokio::available() {
use tokio::net::UnixStream;
@ -269,18 +258,30 @@ pub async fn connect_uds<P: AsRef<Path>, Ws: WithSocket>(
return Ok(with_socket.with_socket(stream));
}
#[cfg(all(unix, feature = "_rt-async-std"))]
#[cfg(feature = "_rt-async-std")]
{
use async_io::Async;
use std::os::unix::net::UnixStream;
let stream = Async::<UnixStream>::connect(path).await?;
return Ok(with_socket.with_socket(stream));
Ok(with_socket.with_socket(stream))
}
#[cfg(all(unix, not(feature = "_rt-async-std")))]
#[cfg(not(feature = "_rt-async-std"))]
{
crate::rt::missing_rt((path, with_socket))
}
}
#[cfg(not(unix))]
{
drop((path, with_socket));
Err(io::Error::new(
io::ErrorKind::Unsupported,
"Unix domain sockets are not supported on this platform",
)
.into())
}
}

4
sqlx-core/src/net/tls/tls_rustls.rs
View file

@ -241,9 +241,7 @@ impl ServerCertVerifier for NoHostnameTlsVerifier {
ocsp_response,
now,
) {
Err(TlsError::InvalidCertificate(reason))
if reason == CertificateError::NotValidForName =>
{
Err(TlsError::InvalidCertificate(CertificateError::NotValidForName)) => {
Ok(ServerCertVerified::assertion())
}
res => res,

8
sqlx-core/src/pool/executor.rs
View file

@ -15,12 +15,12 @@ where
{
type Database = DB;
fn fetch_many<'e, 'q: 'e, E: 'q>(
fn fetch_many<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxStream<'e, Result<Either<DB::QueryResult, DB::Row>, Error>>
where
E: Execute<'q, Self::Database>,
E: 'q + Execute<'q, Self::Database>,
{
let pool = self.clone();
@ -36,12 +36,12 @@ where
})
}
fn fetch_optional<'e, 'q: 'e, E: 'q>(
fn fetch_optional<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxFuture<'e, Result<Option<DB::Row>, Error>>
where
E: Execute<'q, Self::Database>,
E: 'q + Execute<'q, Self::Database>,
{
let pool = self.clone();

20
sqlx-core/src/pool/inner.rs
View file

@ -153,7 +153,7 @@ impl<DB: Database> PoolInner<DB> {
if parent_close_event.as_mut().poll(cx).is_ready() {
// Propagate the parent's close event to the child.
let _ = self.close();
self.mark_closed();
return Poll::Ready(Err(Error::PoolClosed));
}
@ -208,7 +208,7 @@ impl<DB: Database> PoolInner<DB> {
let Floating { inner: idle, guard } = floating.into_idle();
if !self.idle_conns.push(idle).is_ok() {
if self.idle_conns.push(idle).is_err() {
panic!("BUG: connection queue overflow in release()");
}
@ -226,7 +226,7 @@ impl<DB: Database> PoolInner<DB> {
self: &'a Arc<Self>,
permit: AsyncSemaphoreReleaser<'a>,
) -> Result<DecrementSizeGuard<DB>, AsyncSemaphoreReleaser<'a>> {
match self
let result = self
.size
.fetch_update(Ordering::AcqRel, Ordering::Acquire, |size| {
if self.is_closed() {
@ -235,7 +235,9 @@ impl<DB: Database> PoolInner<DB> {
size.checked_add(1)
.filter(|size| size <= &self.options.max_connections)
}) {
});
match result {
// we successfully incremented the size
Ok(_) => Ok(DecrementSizeGuard::from_permit((*self).clone(), permit)),
// the pool is at max capacity or is closed
@ -332,10 +334,10 @@ impl<DB: Database> PoolInner<DB> {
}
let mut backoff = Duration::from_millis(10);
let max_backoff = deadline_as_timeout::<DB>(deadline)? / 5;
let max_backoff = deadline_as_timeout(deadline)? / 5;
loop {
let timeout = deadline_as_timeout::<DB>(deadline)?;
let timeout = deadline_as_timeout(deadline)?;
// clone the connect options arc so it can be used without holding the RwLockReadGuard
// across an async await point
@ -505,9 +507,9 @@ async fn check_idle_conn<DB: Database>(
}
fn spawn_maintenance_tasks<DB: Database>(pool: &Arc<PoolInner<DB>>) {
// NOTE: use `pool_weak` for the maintenance tasks so
// they don't keep `PoolInner` from being dropped.
let pool_weak = Arc::downgrade(&pool);
// NOTE: use `pool_weak` for the maintenance tasks
// so they don't keep `PoolInner` from being dropped.
let pool_weak = Arc::downgrade(pool);
let period = match (pool.options.max_lifetime, pool.options.idle_timeout) {
(Some(it), None) | (None, Some(it)) => it,

4
sqlx-core/src/pool/mod.rs
View file

@ -376,7 +376,7 @@ impl<DB: Database> Pool<DB> {
/// Retrieves a connection and immediately begins a new transaction.
pub async fn begin(&self) -> Result<Transaction<'static, DB>, Error> {
Ok(Transaction::begin(MaybePoolConnection::PoolConnection(self.acquire().await?)).await?)
Transaction::begin(MaybePoolConnection::PoolConnection(self.acquire().await?)).await
}
/// Attempts to retrieve a connection and immediately begins a new transaction if successful.
@ -642,7 +642,7 @@ impl FusedFuture for CloseEvent {
/// get the time between the deadline and now and use that as our timeout
///
/// returns `Error::PoolTimedOut` if the deadline is in the past
fn deadline_as_timeout<DB: Database>(deadline: Instant) -> Result<Duration, Error> {
fn deadline_as_timeout(deadline: Instant) -> Result<Duration, Error> {
deadline
.checked_duration_since(Instant::now())
.ok_or(Error::PoolTimedOut)

2
sqlx-core/src/pool/options.rs
View file

@ -106,7 +106,7 @@ impl<DB: Database> Clone for PoolOptions<DB> {
max_lifetime: self.max_lifetime,
idle_timeout: self.idle_timeout,
fair: self.fair,
parent_pool: self.parent_pool.as_ref().map(Pool::clone),
parent_pool: self.parent_pool.clone(),
}
}
}

6
sqlx-core/src/query.rs
View file

@ -46,14 +46,14 @@ where
#[inline]
fn sql(&self) -> &'q str {
match self.statement {
Either::Right(ref statement) => statement.sql(),
Either::Right(statement) => statement.sql(),
Either::Left(sql) => sql,
}
}
fn statement(&self) -> Option<&DB::Statement<'q>> {
match self.statement {
Either::Right(ref statement) => Some(&statement),
Either::Right(statement) => Some(statement),
Either::Left(_) => None,
}
}
@ -364,7 +364,7 @@ where
let mut f = self.mapper;
Map {
inner: self.inner,
mapper: move |row| f(row).and_then(|o| g(o)),
mapper: move |row| f(row).and_then(&mut g),
}
}

17
sqlx-core/src/rt/mod.rs
View file

@ -33,9 +33,9 @@ pub async fn timeout<F: Future>(duration: Duration, f: F) -> Result<F::Output, T
#[cfg(feature = "_rt-async-std")]
{
return async_std::future::timeout(duration, f)
async_std::future::timeout(duration, f)
.await
.map_err(|_| TimeoutError(()));
.map_err(|_| TimeoutError(()))
}
#[cfg(not(feature = "_rt-async-std"))]
@ -50,7 +50,7 @@ pub async fn sleep(duration: Duration) {
#[cfg(feature = "_rt-async-std")]
{
return async_std::task::sleep(duration).await;
async_std::task::sleep(duration).await
}
#[cfg(not(feature = "_rt-async-std"))]
@ -70,7 +70,7 @@ where
#[cfg(feature = "_rt-async-std")]
{
return JoinHandle::AsyncStd(async_std::task::spawn(fut));
JoinHandle::AsyncStd(async_std::task::spawn(fut))
}
#[cfg(not(feature = "_rt-async-std"))]
@ -90,7 +90,7 @@ where
#[cfg(feature = "_rt-async-std")]
{
return JoinHandle::AsyncStd(async_std::task::spawn_blocking(f));
JoinHandle::AsyncStd(async_std::task::spawn_blocking(f))
}
#[cfg(not(feature = "_rt-async-std"))]
@ -105,7 +105,7 @@ pub async fn yield_now() {
#[cfg(feature = "_rt-async-std")]
{
return async_std::task::yield_now().await;
async_std::task::yield_now().await;
}
#[cfg(not(feature = "_rt-async-std"))]
@ -125,13 +125,12 @@ pub fn test_block_on<F: Future>(f: F) -> F::Output {
#[cfg(all(feature = "_rt-async-std", not(feature = "_rt-tokio")))]
{
return async_std::task::block_on(f);
async_std::task::block_on(f)
}
#[cfg(not(any(feature = "_rt-async-std", feature = "_rt-tokio")))]
{
drop(f);
panic!("at least one of the `runtime-*` features must be enabled")
missing_rt(f)
}
}

12
sqlx-core/src/sync.rs
View file

@ -126,17 +126,15 @@ pub struct AsyncSemaphoreReleaser<'a> {
impl AsyncSemaphoreReleaser<'_> {
pub fn disarm(self) {
#[cfg(feature = "_rt-tokio")]
{
self.inner.forget();
}
#[cfg(all(feature = "_rt-async-std", not(feature = "_rt-tokio")))]
{
let mut this = self;
this.inner.disarm();
return;
}
#[cfg(feature = "_rt-tokio")]
{
self.inner.forget();
return;
}
#[cfg(not(any(feature = "_rt-async-std", feature = "_rt-tokio")))]

1
sqlx-core/src/testing/fixtures.rs
View file

@ -109,6 +109,7 @@ impl<DB: Database> FixtureSnapshot<DB> {
/// Implements `ToString` but not `Display` because it uses [`QueryBuilder`] internally,
/// which appends to an internal string.
#[allow(clippy::to_string_trait_impl)]
impl<DB: Database> ToString for Fixture<DB>
where
for<'a> <DB as Database>::Arguments<'a>: Default,

2
sqlx-core/src/type_checking.rs
View file

@ -111,7 +111,7 @@ where
DB: Database,
{
fn fmt(&self, f: &mut Formatter<'_>) -> fmt::Result {
(self.fmt)(&self.value, f)
(self.fmt)(self.value, f)
}
}

4
sqlx-macros-core/src/database/mod.rs
View file

@ -45,16 +45,16 @@ impl<DB: DatabaseExt> CachingDescribeBlocking<DB> {
where
for<'a> &'a mut DB::Connection: Executor<'a, Database = DB>,
{
crate::block_on(async {
let mut cache = self
.connections
.lock()
.expect("previous panic in describe call");
crate::block_on(async {
let conn = match cache.entry(database_url.to_string()) {
hash_map::Entry::Occupied(hit) => hit.into_mut(),
hash_map::Entry::Vacant(miss) => {
miss.insert(DB::Connection::connect(&database_url).await?)
miss.insert(DB::Connection::connect(database_url).await?)
}
};

7
sqlx-macros-core/src/derives/attributes.rs
View file

@ -41,6 +41,7 @@ impl TypeName {
}
#[derive(Copy, Clone)]
#[allow(clippy::enum_variant_names)]
pub enum RenameAll {
LowerCase,
SnakeCase,
@ -165,7 +166,7 @@ pub fn parse_child_attributes(input: &[Attribute]) -> syn::Result<SqlxChildAttri
json = true;
}
return Ok(());
Ok(())
})?;
if json && flatten {
@ -265,8 +266,8 @@ pub fn check_strong_enum_attributes(
Ok(attributes)
}
pub fn check_struct_attributes<'a>(
input: &'a DeriveInput,
pub fn check_struct_attributes(
input: &DeriveInput,
fields: &Punctuated<Field, Comma>,
) -> syn::Result<SqlxContainerAttributes> {
let attributes = parse_container_attributes(&input.attrs)?;

6
sqlx-macros-core/src/derives/decode.rs
View file

@ -95,7 +95,7 @@ fn expand_derive_decode_weak_enum(
input: &DeriveInput,
variants: &Punctuated<Variant, Comma>,
) -> syn::Result<TokenStream> {
let attr = check_weak_enum_attributes(input, &variants)?;
let attr = check_weak_enum_attributes(input, variants)?;
let repr = attr.repr.unwrap();
let ident = &input.ident;
@ -142,7 +142,7 @@ fn expand_derive_decode_strong_enum(
input: &DeriveInput,
variants: &Punctuated<Variant, Comma>,
) -> syn::Result<TokenStream> {
let cattr = check_strong_enum_attributes(input, &variants)?;
let cattr = check_strong_enum_attributes(input, variants)?;
let ident = &input.ident;
let ident_s = ident.to_string();
@ -154,7 +154,7 @@ fn expand_derive_decode_strong_enum(
if let Some(rename) = attributes.rename {
parse_quote!(#rename => ::std::result::Result::Ok(#ident :: #id),)
} else if let Some(pattern) = cattr.rename_all {
let name = rename_all(&*id.to_string(), pattern);
let name = rename_all(&id.to_string(), pattern);
parse_quote!(#name => ::std::result::Result::Ok(#ident :: #id),)
} else {

10
sqlx-macros-core/src/derives/encode.rs
View file

@ -20,7 +20,7 @@ pub fn expand_derive_encode(input: &DeriveInput) -> syn::Result<TokenStream> {
fields: Fields::Unnamed(FieldsUnnamed { unnamed, .. }),
..
}) if unnamed.len() == 1 => {
expand_derive_encode_transparent(&input, unnamed.first().unwrap())
expand_derive_encode_transparent(input, unnamed.first().unwrap())
}
Data::Enum(DataEnum { variants, .. }) => match args.repr {
Some(_) => expand_derive_encode_weak_enum(input, variants),
@ -104,7 +104,7 @@ fn expand_derive_encode_weak_enum(
input: &DeriveInput,
variants: &Punctuated<Variant, Comma>,
) -> syn::Result<TokenStream> {
let attr = check_weak_enum_attributes(input, &variants)?;
let attr = check_weak_enum_attributes(input, variants)?;
let repr = attr.repr.unwrap();
let ident = &input.ident;
@ -143,7 +143,7 @@ fn expand_derive_encode_strong_enum(
input: &DeriveInput,
variants: &Punctuated<Variant, Comma>,
) -> syn::Result<TokenStream> {
let cattr = check_strong_enum_attributes(input, &variants)?;
let cattr = check_strong_enum_attributes(input, variants)?;
let ident = &input.ident;
@ -156,7 +156,7 @@ fn expand_derive_encode_strong_enum(
if let Some(rename) = attributes.rename {
value_arms.push(quote!(#ident :: #id => #rename,));
} else if let Some(pattern) = cattr.rename_all {
let name = rename_all(&*id.to_string(), pattern);
let name = rename_all(&id.to_string(), pattern);
value_arms.push(quote!(#ident :: #id => #name,));
} else {
@ -197,7 +197,7 @@ fn expand_derive_encode_struct(
input: &DeriveInput,
fields: &Punctuated<Field, Comma>,
) -> syn::Result<TokenStream> {
check_struct_attributes(input, &fields)?;
check_struct_attributes(input, fields)?;
let mut tts = TokenStream::new();

12
sqlx-macros-core/src/derives/row.rs
View file

@ -65,16 +65,14 @@ fn expand_derive_from_row_struct(
let container_attributes = parse_container_attributes(&input.attrs)?;
let default_instance: Option<Stmt>;
if container_attributes.default {
let default_instance: Option<Stmt> = if container_attributes.default {
predicates.push(parse_quote!(#ident: ::std::default::Default));
default_instance = Some(parse_quote!(
Some(parse_quote!(
let __default = #ident::default();
));
))
} else {
default_instance = None;
}
None
};
let reads: Vec<Stmt> = fields
.iter()

6
sqlx-macros-core/src/lib.rs
View file

@ -69,11 +69,13 @@ where
.expect("failed to start Tokio runtime")
});
return TOKIO_RT.block_on(f);
TOKIO_RT.block_on(f)
}
#[cfg(all(feature = "_rt-async-std", not(feature = "tokio")))]
return async_std::task::block_on(f);
{
async_std::task::block_on(f)
}
#[cfg(not(any(feature = "_rt-async-std", feature = "tokio")))]
sqlx_core::rt::missing_rt(f)

4
sqlx-macros-core/src/migrate.rs
View file

@ -20,7 +20,7 @@ impl ToTokens for QuoteMigrationType {
quote! { ::sqlx::migrate::MigrationType::ReversibleDown }
}
};
tokens.append_all(ts.into_iter());
tokens.append_all(ts);
}
}
@ -77,7 +77,7 @@ impl ToTokens for QuoteMigration {
}
};
tokens.append_all(ts.into_iter());
tokens.append_all(ts);
}
}

4
sqlx-macros-core/src/query/args.rs
View file

@ -56,9 +56,9 @@ pub fn quote_args<DB: DatabaseExt>(
}
let param_ty =
DB::param_type_for_id(&param_ty)
DB::param_type_for_id(param_ty)
.ok_or_else(|| {
if let Some(feature_gate) = DB::get_feature_gate(&param_ty) {
if let Some(feature_gate) = DB::get_feature_gate(param_ty) {
format!(
"optional sqlx feature `{}` required for type {} of param #{}",
feature_gate,

18
sqlx-macros-core/src/query/mod.rs
View file

@ -85,8 +85,8 @@ impl Metadata {
let cargo = env("CARGO").expect("`CARGO` must be set");
let output = Command::new(&cargo)
.args(&["metadata", "--format-version=1", "--no-deps"])
let output = Command::new(cargo)
.args(["metadata", "--format-version=1", "--no-deps"])
.current_dir(&self.manifest_dir)
.env_remove("__CARGO_FIX_PLZ")
.output()
@ -190,7 +190,7 @@ pub fn expand_input<'a>(
};
for driver in drivers {
if data_source.matches_driver(&driver) {
if data_source.matches_driver(driver) {
return (driver.expand)(input, data_source);
}
}
@ -222,7 +222,7 @@ where
let (query_data, offline): (QueryData<DB>, bool) = match data_source {
QueryDataSource::Cached(dyn_data) => (QueryData::from_dyn_data(dyn_data)?, true),
QueryDataSource::Live { database_url, .. } => {
let describe = DB::describe_blocking(&input.sql, &database_url)?;
let describe = DB::describe_blocking(&input.sql, database_url)?;
(QueryData::from_describe(&input.sql, describe), false)
}
};
@ -295,13 +295,9 @@ where
}
}
let record_fields = columns.iter().map(
|&output::RustColumn {
ref ident,
ref type_,
..
}| quote!(#ident: #type_,),
);
let record_fields = columns
.iter()
.map(|output::RustColumn { ident, type_, .. }| quote!(#ident: #type_,));
let mut record_tokens = quote! {
#[derive(Debug)]

18
sqlx-macros-core/src/query/output.rs
View file

@ -86,7 +86,7 @@ fn column_to_rust<DB: DatabaseExt>(describe: &Describe<DB>, i: usize) -> crate::
let column = &describe.columns()[i];
// add raw prefix to all identifiers
let decl = ColumnDecl::parse(&column.name())
let decl = ColumnDecl::parse(column.name())
.map_err(|e| format!("column name {:?} is invalid: {}", column.name(), e))?;
let ColumnOverride { nullability, type_ } = decl.r#override;
@ -133,10 +133,8 @@ pub fn quote_query_as<DB: DatabaseExt>(
let instantiations = columns.iter().enumerate().map(
|(
i,
&RustColumn {
ref var_name,
ref type_,
..
RustColumn {
var_name, type_, ..
},
)| {
match (input.checked, type_) {
@ -221,19 +219,19 @@ pub fn quote_query_scalar<DB: DatabaseExt>(
}
fn get_column_type<DB: DatabaseExt>(i: usize, column: &DB::Column) -> TokenStream {
let type_info = &*column.type_info();
let type_info = column.type_info();
<DB as TypeChecking>::return_type_for_id(&type_info).map_or_else(
<DB as TypeChecking>::return_type_for_id(type_info).map_or_else(
|| {
let message =
if let Some(feature_gate) = <DB as TypeChecking>::get_feature_gate(&type_info) {
if let Some(feature_gate) = <DB as TypeChecking>::get_feature_gate(type_info) {
format!(
"optional sqlx feature `{feat}` required for type {ty} of {col}",
ty = &type_info,
feat = feature_gate,
col = DisplayColumn {
idx: i,
name: &*column.name()
name: column.name()
}
)
} else {
@ -242,7 +240,7 @@ fn get_column_type<DB: DatabaseExt>(i: usize, column: &DB::Column) -> TokenStrea
ty = type_info,
col = DisplayColumn {
idx: i,
name: &*column.name()
name: column.name()
}
)
};

2
sqlx-mysql/src/column.rs
View file

@ -22,7 +22,7 @@ impl Column for MySqlColumn {
}
fn name(&self) -> &str {
&*self.name
&self.name
}
fn type_info(&self) -> &MySqlTypeInfo {

12
sqlx-mysql/src/connection/auth.rs
View file

@ -87,7 +87,7 @@ fn scramble_sha1(
let mut pw_hash = ctx.finalize_reset();
ctx.update(&pw_hash);
ctx.update(pw_hash);
let pw_hash_hash = ctx.finalize_reset();
@ -114,7 +114,7 @@ fn scramble_sha256(
let mut pw_hash = ctx.finalize_reset();
ctx.update(&pw_hash);
ctx.update(pw_hash);
let pw_hash_hash = ctx.finalize_reset();
@ -155,10 +155,10 @@ async fn encrypt_rsa<'s>(
let (a, b) = (nonce.first_ref(), nonce.last_ref());
let mut nonce = Vec::with_capacity(a.len() + b.len());
nonce.extend_from_slice(&*a);
nonce.extend_from_slice(&*b);
nonce.extend_from_slice(a);
nonce.extend_from_slice(b);
xor_eq(&mut pass, &*nonce);
xor_eq(&mut pass, &nonce);
// client sends an RSA encrypted password
let pkey = parse_rsa_pub_key(rsa_pub_key)?;
@ -193,5 +193,5 @@ fn parse_rsa_pub_key(key: &[u8]) -> Result<RsaPublicKey, Error> {
// we are receiving a PKCS#8 RSA Public Key at all
// times from MySQL
RsaPublicKey::from_public_key_pem(&pem).map_err(Error::protocol)
RsaPublicKey::from_public_key_pem(pem).map_err(Error::protocol)
}

15
sqlx-mysql/src/connection/executor.rs
View file

@ -245,13 +245,15 @@ impl MySqlConnection {
impl<'c> Executor<'c> for &'c mut MySqlConnection {
type Database = MySql;
fn fetch_many<'e, 'q: 'e, E: 'q>(
fn fetch_many<'e, 'q, E>(
self,
mut query: E,
) -> BoxStream<'e, Result<Either<MySqlQueryResult, MySqlRow>, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>,
'q: 'e,
E: 'q,
{
let sql = query.sql();
let arguments = query.take_arguments().map_err(Error::Encode);
@ -270,13 +272,12 @@ impl<'c> Executor<'c> for &'c mut MySqlConnection {
})
}
fn fetch_optional<'e, 'q: 'e, E: 'q>(
self,
query: E,
) -> BoxFuture<'e, Result<Option<MySqlRow>, Error>>
fn fetch_optional<'e, 'q, E>(self, query: E) -> BoxFuture<'e, Result<Option<MySqlRow>, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>,
'q: 'e,
E: 'q,
{
let mut s = self.fetch_many(query);
@ -338,7 +339,7 @@ impl<'c> Executor<'c> for &'c mut MySqlConnection {
.send_packet(StmtClose { statement: id })
.await?;
let columns = (&*metadata.columns).clone();
let columns = (*metadata.columns).clone();
let nullable = columns
.iter()
@ -384,7 +385,7 @@ fn recv_next_result_column(def: &ColumnDefinition, ordinal: usize) -> Result<MyS
(name, _) => UStr::new(name),
};
let type_info = MySqlTypeInfo::from_column(&def);
let type_info = MySqlTypeInfo::from_column(def);
Ok(MySqlColumn {
name,

6
sqlx-mysql/src/options/mod.rs
View file

@ -119,7 +119,7 @@ impl MySqlConnectOptions {
/// The default behavior when the host is not specified,
/// is to connect to localhost.
pub fn host(mut self, host: &str) -> Self {
self.host = host.to_owned();
host.clone_into(&mut self.host);
self
}
@ -142,7 +142,7 @@ impl MySqlConnectOptions {
/// Sets the username to connect as.
pub fn username(mut self, username: &str) -> Self {
self.username = username.to_owned();
username.clone_into(&mut self.username);
self
}
@ -302,7 +302,7 @@ impl MySqlConnectOptions {
/// The default character set is `utf8mb4`. This is supported from MySQL 5.5.3.
/// If you need to connect to an older version, we recommend you to change this to `utf8`.
pub fn charset(mut self, charset: &str) -> Self {
self.charset = charset.to_owned();
charset.clone_into(&mut self.charset);
self
}

14
sqlx-mysql/src/options/parse.rs
View file

@ -22,7 +22,7 @@ impl MySqlConnectOptions {
let username = url.username();
if !username.is_empty() {
options = options.username(
&*percent_decode_str(username)
&percent_decode_str(username)
.decode_utf8()
.map_err(Error::config)?,
);
@ -30,7 +30,7 @@ impl MySqlConnectOptions {
if let Some(password) = url.password() {
options = options.password(
&*percent_decode_str(password)
&percent_decode_str(password)
.decode_utf8()
.map_err(Error::config)?,
);
@ -52,11 +52,11 @@ impl MySqlConnectOptions {
}
"charset" => {
options = options.charset(&*value);
options = options.charset(&value);
}
"collation" => {
options = options.collation(&*value);
options = options.collation(&value);
}
"sslcert" | "ssl-cert" => options = options.ssl_client_cert(&*value),
@ -87,12 +87,12 @@ impl MySqlConnectOptions {
.expect("BUG: generated un-parseable URL");
if let Some(password) = &self.password {
let password = utf8_percent_encode(&password, NON_ALPHANUMERIC).to_string();
let password = utf8_percent_encode(password, NON_ALPHANUMERIC).to_string();
let _ = url.set_password(Some(&password));
}
if let Some(database) = &self.database {
url.set_path(&database);
url.set_path(database);
}
let ssl_mode = match self.ssl_mode {
@ -112,7 +112,7 @@ impl MySqlConnectOptions {
url.query_pairs_mut().append_pair("charset", &self.charset);
if let Some(collation) = &self.collation {
url.query_pairs_mut().append_pair("charset", &collation);
url.query_pairs_mut().append_pair("charset", collation);
}
if let Some(ssl_client_cert) = &self.ssl_client_cert {

9
sqlx-mysql/src/options/ssl_mode.rs
View file

@ -4,7 +4,7 @@ use std::str::FromStr;
/// Options for controlling the desired security state of the connection to the MySQL server.
///
/// It is used by the [`ssl_mode`](super::MySqlConnectOptions::ssl_mode) method.
#[derive(Debug, Clone, Copy)]
#[derive(Debug, Clone, Copy, Default)]
pub enum MySqlSslMode {
/// Establish an unencrypted connection.
Disabled,
@ -13,6 +13,7 @@ pub enum MySqlSslMode {
/// back to an unencrypted connection if an encrypted connection cannot be established.
///
/// This is the default if `ssl_mode` is not specified.
#[default]
Preferred,
/// Establish an encrypted connection if the server supports encrypted connections.
@ -30,12 +31,6 @@ pub enum MySqlSslMode {
VerifyIdentity,
}
impl Default for MySqlSslMode {
fn default() -> Self {
MySqlSslMode::Preferred
}
}
impl FromStr for MySqlSslMode {
type Err = Error;

2
sqlx-mysql/src/protocol/auth.rs
View file

@ -3,6 +3,8 @@ use std::str::FromStr;
use crate::error::Error;
#[derive(Debug, Copy, Clone)]
// These have all the same suffix but they match the auth plugin names.
#[allow(clippy::enum_variant_names)]
pub enum AuthPlugin {
MySqlNativePassword,
CachingSha2Password,

3
sqlx-mysql/src/protocol/connect/handshake.rs
View file

@ -1,5 +1,6 @@
use bytes::buf::Chain;
use bytes::{Buf, Bytes};
use std::cmp;
use crate::error::Error;
use crate::io::{BufExt, Decode};
@ -61,7 +62,7 @@ impl Decode<'_> for Handshake {
}
let auth_plugin_data_2 = if capabilities.contains(Capabilities::SECURE_CONNECTION) {
let len = ((auth_plugin_data_len as isize) - 9).max(12) as usize;
let len = cmp::max((auth_plugin_data_len as isize) - 9, 12) as usize;
let v = buf.get_bytes(len);
buf.advance(1); // NUL-terminator

2
sqlx-mysql/src/protocol/response/err.rs
View file

@ -30,7 +30,7 @@ impl Decode<'_, Capabilities> for ErrPacket {
if capabilities.contains(Capabilities::PROTOCOL_41) {
// If the next byte is '#' then we have a SQL STATE
if buf.get(0) == Some(&0x23) {
if buf.starts_with(b"#") {
buf.advance(1);
sql_state = Some(buf.get_str(5)?);
}

4
sqlx-mysql/src/protocol/row.rs
View file

@ -10,8 +10,6 @@ pub(crate) struct Row {
impl Row {
pub(crate) fn get(&self, index: usize) -> Option<&[u8]> {
self.values[index]
.as_ref()
.map(|col| &self.storage[(col.start as usize)..(col.end as usize)])
self.values[index].clone().map(|col| &self.storage[col])
}
}

2
sqlx-mysql/src/row.rs
View file

@ -46,6 +46,6 @@ impl ColumnIndex<MySqlRow> for &'_ str {
row.column_names
.get(*self)
.ok_or_else(|| Error::ColumnNotFound((*self).into()))
.map(|v| *v)
.copied()
}
}

2
sqlx-mysql/src/statement.rs
View file

@ -55,6 +55,6 @@ impl ColumnIndex<MySqlStatement<'_>> for &'_ str {
.column_names
.get(*self)
.ok_or_else(|| Error::ColumnNotFound((*self).into()))
.map(|v| *v)
.copied()
}
}

13
sqlx-mysql/src/testing/mod.rs
View file

@ -27,10 +27,7 @@ static DO_CLEANUP: AtomicBool = AtomicBool::new(true);
impl TestSupport for MySql {
fn test_context(args: &TestArgs) -> BoxFuture<'_, Result<TestContext<Self>, Error>> {
Box::pin(async move {
let res = test_context(args).await;
res
})
Box::pin(async move { test_context(args).await })
}
fn cleanup_test(db_name: &str) -> BoxFuture<'_, Result<(), Error>> {
@ -47,7 +44,7 @@ impl TestSupport for MySql {
.await?;
query("delete from _sqlx_test_databases where db_id = ?")
.bind(&db_id)
.bind(db_id)
.execute(&mut *conn)
.await?;
@ -141,7 +138,7 @@ async fn test_context(args: &TestArgs) -> Result<TestContext<MySql>, Error> {
}
query("insert into _sqlx_test_databases(test_path) values (?)")
.bind(&args.test_path)
.bind(args.test_path)
.execute(&mut *conn)
.await?;
@ -182,7 +179,7 @@ async fn do_cleanup(conn: &mut MySqlConnection, created_before: Duration) -> Res
"select db_id from _sqlx_test_databases \
where created_at < from_unixtime(?)",
)
.bind(&created_before_as_secs)
.bind(created_before_as_secs)
.fetch_all(&mut *conn)
.await?;
@ -221,8 +218,6 @@ async fn do_cleanup(conn: &mut MySqlConnection, created_before: Duration) -> Res
separated.push_bind(db_id);
}
drop(separated);
query.push(")").build().execute(&mut *conn).await?;
Ok(deleted_db_ids.len())

2
sqlx-mysql/src/transaction.rs
View file

@ -59,7 +59,7 @@ impl TransactionManager for MySqlTransactionManager {
conn.inner.stream.sequence_id = 0;
conn.inner
.stream
.write_packet(Query(&*rollback_ansi_transaction_sql(depth)));
.write_packet(Query(&rollback_ansi_transaction_sql(depth)));
conn.inner.transaction_depth = depth - 1;
}

6
sqlx-mysql/src/types/chrono.rs
View file

@ -25,7 +25,7 @@ impl Type<MySql> for DateTime<Utc> {
/// Note: assumes the connection's `time_zone` is set to `+00:00` (UTC).
impl Encode<'_, MySql> for DateTime<Utc> {
fn encode_by_ref(&self, buf: &mut Vec<u8>) -> Result<IsNull, BoxDynError> {
Encode::<MySql>::encode(&self.naive_utc(), buf)
Encode::<MySql>::encode(self.naive_utc(), buf)
}
}
@ -51,7 +51,7 @@ impl Type<MySql> for DateTime<Local> {
/// Note: assumes the connection's `time_zone` is set to `+00:00` (UTC).
impl Encode<'_, MySql> for DateTime<Local> {
fn encode_by_ref(&self, buf: &mut Vec<u8>) -> Result<IsNull, BoxDynError> {
Encode::<MySql>::encode(&self.naive_utc(), buf)
Encode::<MySql>::encode(self.naive_utc(), buf)
}
}
@ -318,7 +318,7 @@ fn encode_time(time: &NaiveTime, include_micros: bool, buf: &mut Vec<u8>) {
buf.push(time.second() as u8);
if include_micros {
buf.extend(&((time.nanosecond() / 1000) as u32).to_le_bytes());
buf.extend((time.nanosecond() / 1000).to_le_bytes());
}
}

4
sqlx-mysql/src/types/mysql_time.rs
View file

@ -498,7 +498,7 @@ impl MySqlTimeSign {
}
}
fn to_byte(&self) -> u8 {
fn to_byte(self) -> u8 {
match self {
// We can't use `#[repr(u8)]` because this is opposite of the ordering we want from `Ord`
Self::Negative => 1,
@ -579,7 +579,7 @@ fn parse(text: &str) -> Result<MySqlTime, BoxDynError> {
MySqlTimeSign::Positive
};
let hours = hours.abs() as u32;
let hours = hours.unsigned_abs();
let minutes: u8 = minutes
.parse()

8
sqlx-mysql/src/types/time.rs
View file

@ -27,7 +27,7 @@ impl Encode<'_, MySql> for OffsetDateTime {
let utc_dt = self.to_offset(UtcOffset::UTC);
let primitive_dt = PrimitiveDateTime::new(utc_dt.date(), utc_dt.time());
Encode::<MySql>::encode(&primitive_dt, buf)
Encode::<MySql>::encode(primitive_dt, buf)
}
}
@ -287,8 +287,8 @@ fn decode_date(buf: &[u8]) -> Result<Option<Date>, BoxDynError> {
Date::from_calendar_date(
LittleEndian::read_u16(buf) as i32,
time::Month::try_from(buf[2] as u8)?,
buf[3] as u8,
time::Month::try_from(buf[2])?,
buf[3],
)
.map_err(Into::into)
.map(Some)
@ -300,7 +300,7 @@ fn encode_time(time: &Time, include_micros: bool, buf: &mut Vec<u8>) {
buf.push(time.second());
if include_micros {
buf.extend(&((time.nanosecond() / 1000) as u32).to_le_bytes());
buf.extend(&(time.nanosecond() / 1000).to_le_bytes());
}
}

4
sqlx-mysql/src/value.rs
View file

@ -95,7 +95,7 @@ impl<'r> ValueRef<'r> for MySqlValueRef<'r> {
#[inline]
fn is_null(&self) -> bool {
is_null(self.value.as_deref(), &self.type_info)
is_null(self.value, &self.type_info)
}
}
@ -105,7 +105,7 @@ fn is_null(value: Option<&[u8]>, ty: &MySqlTypeInfo) -> bool {
if matches!(
ty.r#type,
ColumnType::Date | ColumnType::Timestamp | ColumnType::Datetime
) && value.get(0) == Some(&0)
) && value.starts_with(b"\0")
{
return true;
}

32
sqlx-postgres/src/arguments.rs
View file

@ -32,12 +32,7 @@ pub struct PgArgumentBuffer {
//
// This currently is only setup to be useful if there is a *fixed-size* slot that needs to be
// tweaked from the input type. However, that's the only use case we currently have.
//
patches: Vec<(
usize, // offset
usize, // argument index
Box<dyn Fn(&mut [u8], &PgTypeInfo) + 'static + Send + Sync>,
)>,
patches: Vec<Patch>,
// Whenever an `Encode` impl encounters a `PgTypeInfo` object that does not have an OID
// It pushes a "hole" that must be patched later.
@ -49,6 +44,13 @@ pub struct PgArgumentBuffer {
type_holes: Vec<(usize, UStr)>, // Vec<{ offset, type_name }>
}
struct Patch {
buf_offset: usize,
arg_index: usize,
#[allow(clippy::type_complexity)]
callback: Box<dyn Fn(&mut [u8], &PgTypeInfo) + 'static + Send + Sync>,
}
/// Implementation of [`Arguments`] for PostgreSQL.
#[derive(Default)]
pub struct PgArguments {
@ -97,15 +99,15 @@ impl PgArguments {
..
} = self.buffer;
for (offset, ty, callback) in patches {
let buf = &mut buffer[*offset..];
let ty = &parameters[*ty];
for patch in patches {
let buf = &mut buffer[patch.buf_offset..];
let ty = &parameters[patch.arg_index];
callback(buf, ty);
(patch.callback)(buf, ty);
}
for (offset, name) in type_holes {
let oid = conn.fetch_type_id_by_name(&*name).await?;
let oid = conn.fetch_type_id_by_name(name).await?;
buffer[*offset..(*offset + 4)].copy_from_slice(&oid.0.to_be_bytes());
}
@ -169,9 +171,13 @@ impl PgArgumentBuffer {
F: Fn(&mut [u8], &PgTypeInfo) + 'static + Send + Sync,
{
let offset = self.len();
let index = self.count;
let arg_index = self.count;
self.patches.push((offset, index, Box::new(callback)));
self.patches.push(Patch {
buf_offset: offset,
arg_index,
callback: Box::new(callback),
});
}
// Extends the inner buffer by enough space to have an OID

2
sqlx-postgres/src/column.rs
View file

@ -23,7 +23,7 @@ impl Column for PgColumn {
}
fn name(&self) -> &str {
&*self.name
&self.name
}
fn type_info(&self) -> &PgTypeInfo {

2
sqlx-postgres/src/connection/describe.rs
View file

@ -463,7 +463,7 @@ WHERE rngtypid = $1
}) = explains.first()
{
nullables.resize(outputs.len(), None);
visit_plan(&plan, outputs, &mut nullables);
visit_plan(plan, outputs, &mut nullables);
}
Ok(nullables)

22
sqlx-postgres/src/connection/executor.rs
View file

@ -48,7 +48,7 @@ async fn prepare(
// next we send the PARSE command to the server
conn.stream.write(Parse {
param_types: &*param_types,
param_types: &param_types,
query: sql,
statement: id,
});
@ -63,8 +63,7 @@ async fn prepare(
conn.stream.flush().await?;
// indicates that the SQL query string is now successfully parsed and has semantic validity
let _ = conn
.stream
conn.stream
.recv_expect(MessageFormat::ParseComplete)
.await?;
@ -227,7 +226,7 @@ impl PgConnection {
statement,
formats: &[PgValueFormat::Binary],
num_params: arguments.types.len() as i16,
params: &*arguments.buffer,
params: &arguments.buffer,
result_formats: &[PgValueFormat::Binary],
});
@ -360,15 +359,19 @@ impl PgConnection {
impl<'c> Executor<'c> for &'c mut PgConnection {
type Database = Postgres;
fn fetch_many<'e, 'q: 'e, E: 'q>(
fn fetch_many<'e, 'q, E>(
self,
mut query: E,
) -> BoxStream<'e, Result<Either<PgQueryResult, PgRow>, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>,
'q: 'e,
E: 'q,
{
let sql = query.sql();
// False positive: https://github.com/rust-lang/rust-clippy/issues/12560
#[allow(clippy::map_clone)]
let metadata = query.statement().map(|s| Arc::clone(&s.metadata));
let arguments = query.take_arguments().map_err(Error::Encode);
let persistent = query.persistent();
@ -386,15 +389,16 @@ impl<'c> Executor<'c> for &'c mut PgConnection {
})
}
fn fetch_optional<'e, 'q: 'e, E: 'q>(
self,
mut query: E,
) -> BoxFuture<'e, Result<Option<PgRow>, Error>>
fn fetch_optional<'e, 'q, E>(self, mut query: E) -> BoxFuture<'e, Result<Option<PgRow>, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>,
'q: 'e,
E: 'q,
{
let sql = query.sql();
// False positive: https://github.com/rust-lang/rust-clippy/issues/12560
#[allow(clippy::map_clone)]
let metadata = query.statement().map(|s| Arc::clone(&s.metadata));
let arguments = query.take_arguments().map_err(Error::Encode);
let persistent = query.persistent();

8
sqlx-postgres/src/connection/sasl.rs
View file

@ -101,7 +101,7 @@ pub(crate) async fn authenticate(
let client_key = mac.finalize().into_bytes();
// StoredKey := H(ClientKey)
let stored_key = Sha256::digest(&client_key);
let stored_key = Sha256::digest(client_key);
// client-final-message-without-proof
let client_final_message_wo_proof = format!(
@ -120,7 +120,7 @@ pub(crate) async fn authenticate(
// ClientSignature := HMAC(StoredKey, AuthMessage)
let mut mac = Hmac::<Sha256>::new_from_slice(&stored_key).map_err(Error::protocol)?;
mac.update(&auth_message.as_bytes());
mac.update(auth_message.as_bytes());
let client_signature = mac.finalize().into_bytes();
@ -139,7 +139,7 @@ pub(crate) async fn authenticate(
// ServerSignature := HMAC(ServerKey, AuthMessage)
let mut mac = Hmac::<Sha256>::new_from_slice(&server_key).map_err(Error::protocol)?;
mac.update(&auth_message.as_bytes());
mac.update(auth_message.as_bytes());
// client-final-message = client-final-message-without-proof "," proof
let mut client_final_message = format!("{client_final_message_wo_proof},{CLIENT_PROOF_ATTR}=");
@ -192,7 +192,7 @@ fn gen_nonce() -> String {
fn hi<'a>(s: &'a str, salt: &'a [u8], iter_count: u32) -> Result<[u8; 32], Error> {
let mut mac = Hmac::<Sha256>::new_from_slice(s.as_bytes()).map_err(Error::protocol)?;
mac.update(&salt);
mac.update(salt);
mac.update(&1u32.to_be_bytes());
let mut u = mac.finalize_reset().into_bytes();

5
sqlx-postgres/src/connection/stream.rs
View file

@ -159,11 +159,10 @@ impl PgStream {
tracing_level
);
if log_is_enabled {
let message = format!("{}", notice.message());
sqlx_core::private_tracing_dynamic_event!(
target: "sqlx::postgres::notice",
tracing_level,
message
message = notice.message()
);
}
@ -211,7 +210,7 @@ fn parse_server_version(s: &str) -> Option<u32> {
break;
}
}
_ if ch.is_digit(10) => {
_ if ch.is_ascii_digit() => {
if chs.peek().is_none() {
if let Ok(num) = u32::from_str(&s[from..]) {
parts.push(num);

11
sqlx-postgres/src/listener.rs
View file

@ -332,13 +332,15 @@ impl Drop for PgListener {
impl<'c> Executor<'c> for &'c mut PgListener {
type Database = Postgres;
fn fetch_many<'e, 'q: 'e, E: 'q>(
fn fetch_many<'e, 'q, E>(
self,
query: E,
) -> BoxStream<'e, Result<Either<PgQueryResult, PgRow>, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>,
'q: 'e,
E: 'q,
{
futures_util::stream::once(async move {
// need some basic type annotation to help the compiler a bit
@ -349,13 +351,12 @@ impl<'c> Executor<'c> for &'c mut PgListener {
.boxed()
}
fn fetch_optional<'e, 'q: 'e, E: 'q>(
self,
query: E,
) -> BoxFuture<'e, Result<Option<PgRow>, Error>>
fn fetch_optional<'e, 'q, E>(self, query: E) -> BoxFuture<'e, Result<Option<PgRow>, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>,
'q: 'e,
E: 'q,
{
async move { self.connection().await?.fetch_optional(query).await }.boxed()
}

4
sqlx-postgres/src/message/authentication.rs
View file

@ -162,8 +162,8 @@ impl Decode<'_> for AuthenticationSaslContinue {
Ok(Self {
iterations,
salt,
nonce: from_utf8(&*nonce).map_err(Error::protocol)?.to_owned(),
message: from_utf8(&*buf).map_err(Error::protocol)?.to_owned(),
nonce: from_utf8(&nonce).map_err(Error::protocol)?.to_owned(),
message: from_utf8(&buf).map_err(Error::protocol)?.to_owned(),
})
}
}

4
sqlx-postgres/src/options/mod.rs
View file

@ -201,7 +201,7 @@ impl PgConnectOptions {
/// .host("localhost");
/// ```
pub fn host(mut self, host: &str) -> Self {
self.host = host.to_owned();
host.clone_into(&mut self.host);
self
}
@ -243,7 +243,7 @@ impl PgConnectOptions {
/// .username("postgres");
/// ```
pub fn username(mut self, username: &str) -> Self {
self.username = username.to_owned();
username.clone_into(&mut self.username);
self
}

26
sqlx-postgres/src/options/parse.rs
View file

@ -24,7 +24,7 @@ impl PgConnectOptions {
let username = url.username();
if !username.is_empty() {
options = options.username(
&*percent_decode_str(username)
&percent_decode_str(username)
.decode_utf8()
.map_err(Error::config)?,
);
@ -32,7 +32,7 @@ impl PgConnectOptions {
if let Some(password) = url.password() {
options = options.password(
&*percent_decode_str(password)
&percent_decode_str(password)
.decode_utf8()
.map_err(Error::config)?,
);
@ -63,32 +63,32 @@ impl PgConnectOptions {
}
"host" => {
if value.starts_with("/") {
if value.starts_with('/') {
options = options.socket(&*value);
} else {
options = options.host(&*value);
options = options.host(&value);
}
}
"hostaddr" => {
value.parse::<IpAddr>().map_err(Error::config)?;
options = options.host(&*value)
options = options.host(&value)
}
"port" => options = options.port(value.parse().map_err(Error::config)?),
"dbname" => options = options.database(&*value),
"dbname" => options = options.database(&value),
"user" => options = options.username(&*value),
"user" => options = options.username(&value),
"password" => options = options.password(&*value),
"password" => options = options.password(&value),
"application_name" => options = options.application_name(&*value),
"application_name" => options = options.application_name(&value),
"options" => {
if let Some(options) = options.options.as_mut() {
options.push(' ');
options.push_str(&*value);
options.push_str(&value);
} else {
options.options = Some(value.to_string());
}
@ -112,7 +112,7 @@ impl PgConnectOptions {
pub(crate) fn build_url(&self) -> Url {
let host = match &self.socket {
Some(socket) => {
utf8_percent_encode(&*socket.to_string_lossy(), NON_ALPHANUMERIC).to_string()
utf8_percent_encode(&socket.to_string_lossy(), NON_ALPHANUMERIC).to_string()
}
None => self.host.to_owned(),
};
@ -124,12 +124,12 @@ impl PgConnectOptions {
.expect("BUG: generated un-parseable URL");
if let Some(password) = &self.password {
let password = utf8_percent_encode(&password, NON_ALPHANUMERIC).to_string();
let password = utf8_percent_encode(password, NON_ALPHANUMERIC).to_string();
let _ = url.set_password(Some(&password));
}
if let Some(database) = &self.database {
url.set_path(&database);
url.set_path(database);
}
let ssl_mode = match self.ssl_mode {

13
sqlx-postgres/src/options/pgpass.rs
View file

@ -41,7 +41,14 @@ fn load_password_from_file(
username: &str,
database: Option<&str>,
) -> Option<String> {
let file = File::open(&path).ok()?;
let file = File::open(&path)
.map_err(|e| {
tracing::warn!(
path = %path.display(),
"Failed to open `.pgpass` file: {e:?}",
);
})
.ok()?;
#[cfg(target_os = "linux")]
{
@ -54,7 +61,7 @@ fn load_password_from_file(
let mode = permissions.mode();
if mode & 0o77 != 0 {
tracing::warn!(
path = %path.to_string_lossy(),
path = %path.display(),
permissions = format!("{mode:o}"),
"Ignoring path. Permissions are not strict enough",
);
@ -184,7 +191,7 @@ fn find_next_field<'a>(line: &mut &'a str) -> Option<Cow<'a, str>> {
}
}
return None;
None
}
#[cfg(test)]

11
sqlx-postgres/src/options/ssl_mode.rs
View file

@ -4,7 +4,7 @@ use std::str::FromStr;
/// Options for controlling the level of protection provided for PostgreSQL SSL connections.
///
/// It is used by the [`ssl_mode`](super::PgConnectOptions::ssl_mode) method.
#[derive(Debug, Clone, Copy)]
#[derive(Debug, Clone, Copy, Default)]
pub enum PgSslMode {
/// Only try a non-SSL connection.
Disable,
@ -13,6 +13,9 @@ pub enum PgSslMode {
Allow,
/// First try an SSL connection; if that fails, try a non-SSL connection.
///
/// This is the default if no other mode is specified.
#[default]
Prefer,
/// Only try an SSL connection. If a root CA file is present, verify the connection
@ -28,12 +31,6 @@ pub enum PgSslMode {
VerifyFull,
}
impl Default for PgSslMode {
fn default() -> Self {
PgSslMode::Prefer
}
}
impl FromStr for PgSslMode {
type Err = Error;

2
sqlx-postgres/src/row.rs
View file

@ -47,7 +47,7 @@ impl ColumnIndex<PgRow> for &'_ str {
.column_names
.get(*self)
.ok_or_else(|| Error::ColumnNotFound((*self).into()))
.map(|v| *v)
.copied()
}
}

2
sqlx-postgres/src/statement.rs
View file

@ -56,7 +56,7 @@ impl ColumnIndex<PgStatement<'_>> for &'_ str {
.column_names
.get(*self)
.ok_or_else(|| Error::ColumnNotFound((*self).into()))
.map(|v| *v)
.copied()
}
}

11
sqlx-postgres/src/testing/mod.rs
View file

@ -26,10 +26,7 @@ static DO_CLEANUP: AtomicBool = AtomicBool::new(true);
impl TestSupport for Postgres {
fn test_context(args: &TestArgs) -> BoxFuture<'_, Result<TestContext<Self>, Error>> {
Box::pin(async move {
let res = test_context(args).await;
res
})
Box::pin(async move { test_context(args).await })
}
fn cleanup_test(db_name: &str) -> BoxFuture<'_, Result<(), Error>> {
@ -44,7 +41,7 @@ impl TestSupport for Postgres {
.await?;
query("delete from _sqlx_test.databases where db_name = $1")
.bind(&db_name)
.bind(db_name)
.execute(&mut *conn)
.await?;
@ -157,7 +154,7 @@ async fn test_context(args: &TestArgs) -> Result<TestContext<Postgres>, Error> {
returning db_name
"#,
)
.bind(&args.test_path)
.bind(args.test_path)
.fetch_one(&mut *conn)
.await?;
@ -190,7 +187,7 @@ async fn do_cleanup(conn: &mut PgConnection, created_before: Duration) -> Result
"select db_name from _sqlx_test.databases \
where created_at < (to_timestamp($1) at time zone 'UTC')",
)
.bind(&created_before)
.bind(created_before)
.fetch_all(&mut *conn)
.await?;

4
sqlx-postgres/src/type_info.rs
View file

@ -561,7 +561,7 @@ impl PgType {
PgType::Money => "MONEY",
PgType::MoneyArray => "MONEY[]",
PgType::Void => "VOID",
PgType::Custom(ty) => &*ty.name,
PgType::Custom(ty) => &ty.name,
PgType::DeclareWithOid(_) => "?",
PgType::DeclareWithName(name) => name,
}
@ -661,7 +661,7 @@ impl PgType {
PgType::Money => "money",
PgType::MoneyArray => "_money",
PgType::Void => "void",
PgType::Custom(ty) => &*ty.name,
PgType::Custom(ty) => &ty.name,
PgType::DeclareWithOid(_) => "?",
PgType::DeclareWithName(name) => name,
}

2
sqlx-postgres/src/types/array.rs
View file

@ -156,7 +156,7 @@ where
T: Encode<'q, Postgres> + Type<Postgres>,
{
fn encode_by_ref(&self, buf: &mut PgArgumentBuffer) -> Result<IsNull, BoxDynError> {
let type_info = if self.len() < 1 {
let type_info = if self.is_empty() {
T::type_info()
} else {
self[0].produces().unwrap_or_else(T::type_info)

2
sqlx-postgres/src/types/bit_vec.rs
View file

@ -66,7 +66,7 @@ impl Decode<'_, Postgres> for BitVec {
))?;
}
let mut bitvec = BitVec::from_bytes(&bytes);
let mut bitvec = BitVec::from_bytes(bytes);
// Chop off zeroes from the back. We get bits in bytes, so if
// our bitvec is not in full bytes, extra zeroes are added to

2
sqlx-postgres/src/types/chrono/date.rs
View file

@ -24,7 +24,7 @@ impl Encode<'_, Postgres> for NaiveDate {
fn encode_by_ref(&self, buf: &mut PgArgumentBuffer) -> Result<IsNull, BoxDynError> {
// DATE is encoded as the days since epoch
let days = (*self - postgres_epoch_date()).num_days() as i32;
Encode::<Postgres>::encode(&days, buf)
Encode::<Postgres>::encode(days, buf)
}
fn size_hint(&self) -> usize {

4
sqlx-postgres/src/types/chrono/datetime.rs
View file

@ -35,11 +35,11 @@ impl<Tz: TimeZone> PgHasArrayType for DateTime<Tz> {
impl Encode<'_, Postgres> for NaiveDateTime {
fn encode_by_ref(&self, buf: &mut PgArgumentBuffer) -> Result<IsNull, BoxDynError> {
// TIMESTAMP is encoded as the microseconds since the epoch
let us = (*self - postgres_epoch_datetime())
let micros = (*self - postgres_epoch_datetime())
.num_microseconds()
.ok_or_else(|| format!("NaiveDateTime out of range for Postgres: {self:?}"))?;
Encode::<Postgres>::encode(&us, buf)
Encode::<Postgres>::encode(micros, buf)
}
fn size_hint(&self) -> usize {

4
sqlx-postgres/src/types/chrono/time.rs
View file

@ -21,11 +21,11 @@ impl PgHasArrayType for NaiveTime {
impl Encode<'_, Postgres> for NaiveTime {
fn encode_by_ref(&self, buf: &mut PgArgumentBuffer) -> Result<IsNull, BoxDynError> {
// TIME is encoded as the microseconds since midnight
let us = (*self - NaiveTime::default())
let micros = (*self - NaiveTime::default())
.num_microseconds()
.ok_or_else(|| format!("Time out of range for PostgreSQL: {self}"))?;
Encode::<Postgres>::encode(&us, buf)
Encode::<Postgres>::encode(micros, buf)
}
fn size_hint(&self) -> usize {

2
sqlx-postgres/src/types/interval.rs
View file

@ -167,7 +167,7 @@ impl TryFrom<chrono::Duration> for PgInterval {
Ok(Self {
months: 0,
days: 0,
microseconds: microseconds,
microseconds,
})
},
)

36
sqlx-postgres/src/types/lquery.rs
View file

@ -75,6 +75,9 @@ impl PgLQuery {
}
/// creates lquery from an iterator with checking labels
// TODO: this should just be removed but I didn't want to bury it in a massive diff
#[deprecated = "renamed to `try_from_iter()`"]
#[allow(clippy::should_implement_trait)]
pub fn from_iter<I, S>(levels: I) -> Result<Self, PgLQueryParseError>
where
S: Into<String>,
@ -86,6 +89,26 @@ impl PgLQuery {
}
Ok(lquery)
}
/// Create an `LQUERY` from an iterator of label strings.
///
/// Returns an error if any label fails to parse according to [`PgLQueryLevel::from_str()`].
pub fn try_from_iter<I, S>(levels: I) -> Result<Self, PgLQueryParseError>
where
S: AsRef<str>,
I: IntoIterator<Item = S>,
{
levels
.into_iter()
.map(|level| level.as_ref().parse::<PgLQueryLevel>())
.collect()
}
}
impl FromIterator<PgLQueryLevel> for PgLQuery {
fn from_iter<T: IntoIterator<Item = PgLQueryLevel>>(iter: T) -> Self {
Self::from(iter.into_iter().collect())
}
}
impl IntoIterator for PgLQuery {
@ -104,7 +127,7 @@ impl FromStr for PgLQuery {
Ok(Self {
levels: s
.split('.')
.map(|s| PgLQueryLevel::from_str(s))
.map(PgLQueryLevel::from_str)
.collect::<Result<_, Self::Err>>()?,
})
}
@ -244,12 +267,12 @@ impl FromStr for PgLQueryLevel {
b'!' => Ok(PgLQueryLevel::NotNonStar(
s[1..]
.split('|')
.map(|s| PgLQueryVariant::from_str(s))
.map(PgLQueryVariant::from_str)
.collect::<Result<Vec<_>, PgLQueryParseError>>()?,
)),
_ => Ok(PgLQueryLevel::NonStar(
s.split('|')
.map(|s| PgLQueryVariant::from_str(s))
.map(PgLQueryVariant::from_str)
.collect::<Result<Vec<_>, PgLQueryParseError>>()?,
)),
}
@ -262,10 +285,9 @@ impl FromStr for PgLQueryVariant {
fn from_str(s: &str) -> Result<Self, Self::Err> {
let mut label_length = s.len();
let mut rev_iter = s.bytes().rev();
let mut modifiers = PgLQueryVariantFlag::empty();
while let Some(b) = rev_iter.next() {
for b in s.bytes().rev() {
match b {
b'@' => modifiers.insert(PgLQueryVariantFlag::IN_CASE),
b'*' => modifiers.insert(PgLQueryVariantFlag::ANY_END),
@ -306,8 +328,8 @@ impl Display for PgLQueryLevel {
PgLQueryLevel::Star(Some(at_least), _) => write!(f, "*{{{at_least},}}"),
PgLQueryLevel::Star(_, Some(at_most)) => write!(f, "*{{,{at_most}}}"),
PgLQueryLevel::Star(_, _) => write!(f, "*"),
PgLQueryLevel::NonStar(variants) => write_variants(f, &variants, false),
PgLQueryLevel::NotNonStar(variants) => write_variants(f, &variants, true),
PgLQueryLevel::NonStar(variants) => write_variants(f, variants, false),
PgLQueryLevel::NotNonStar(variants) => write_variants(f, variants, true),
}
}
}

28
sqlx-postgres/src/types/ltree.rs
View file

@ -27,9 +27,9 @@ pub struct PgLTreeLabel(String);
impl PgLTreeLabel {
pub fn new<S>(label: S) -> Result<Self, PgLTreeParseError>
where
String: From<S>,
S: Into<String>,
{
let label = String::from(label);
let label = label.into();
if label.len() <= 256
&& label
.bytes()
@ -101,6 +101,9 @@ impl PgLTree {
}
/// creates ltree from an iterator with checking labels
// TODO: this should just be removed but I didn't want to bury it in a massive diff
#[deprecated = "renamed to `try_from_iter()`"]
#[allow(clippy::should_implement_trait)]
pub fn from_iter<I, S>(labels: I) -> Result<Self, PgLTreeParseError>
where
String: From<S>,
@ -113,6 +116,17 @@ impl PgLTree {
Ok(ltree)
}
/// Create an `LTREE` from an iterator of label strings.
///
/// Returns an error if any label fails to parse according to [`PgLTreeLabel::new()`].
pub fn try_from_iter<I, S>(labels: I) -> Result<Self, PgLTreeParseError>
where
S: Into<String>,
I: IntoIterator<Item = S>,
{
labels.into_iter().map(PgLTreeLabel::new).collect()
}
/// push a label to ltree
pub fn push(&mut self, label: PgLTreeLabel) {
self.labels.push(label);
@ -124,6 +138,14 @@ impl PgLTree {
}
}
impl FromIterator<PgLTreeLabel> for PgLTree {
fn from_iter<T: IntoIterator<Item = PgLTreeLabel>>(iter: T) -> Self {
Self {
labels: iter.into_iter().collect(),
}
}
}
impl IntoIterator for PgLTree {
type Item = PgLTreeLabel;
type IntoIter = std::vec::IntoIter<Self::Item>;
@ -140,7 +162,7 @@ impl FromStr for PgLTree {
Ok(Self {
labels: s
.split('.')
.map(|s| PgLTreeLabel::new(s))
.map(PgLTreeLabel::new)
.collect::<Result<Vec<_>, Self::Err>>()?,
})
}

2
sqlx-postgres/src/types/mod.rs
View file

@ -261,7 +261,7 @@ fn array_compatible<E: Type<Postgres> + ?Sized>(ty: &PgTypeInfo) -> bool {
// we require the declared type to be an _array_ with an
// element type that is acceptable
if let PgTypeKind::Array(element) = &ty.kind() {
return E::compatible(&element);
return E::compatible(element);
}
false

4
sqlx-postgres/src/types/range.rs
View file

@ -445,7 +445,7 @@ where
}
count += 1;
if !(element.is_empty() && !quoted) {
if !element.is_empty() || quoted {
let value = Some(T::decode(PgValueRef {
type_info: T::type_info(),
format: PgValueFormat::Text,
@ -515,7 +515,7 @@ fn range_compatible<E: Type<Postgres>>(ty: &PgTypeInfo) -> bool {
// we require the declared type to be a _range_ with an
// element type that is acceptable
if let PgTypeKind::Range(element) = &ty.kind() {
return E::compatible(&element);
return E::compatible(element);
}
false

6
sqlx-postgres/src/types/rust_decimal.rs
View file

@ -103,9 +103,9 @@ impl From<&'_ Decimal> for PgNumeric {
let groups_diff = scale % 4;
if groups_diff > 0 {
let remainder = 4 - groups_diff as u32;
let power = 10u32.pow(remainder as u32) as u128;
let power = 10u32.pow(remainder) as u128;
mantissa = mantissa * power;
mantissa *= power;
}
// Array to store max mantissa of Decimal in Postgres decimal format.
@ -121,7 +121,7 @@ impl From<&'_ Decimal> for PgNumeric {
digits.reverse();
// Weight is number of digits on the left side of the decimal.
let digits_after_decimal = (scale + 3) as u16 / 4;
let digits_after_decimal = (scale + 3) / 4;
let weight = digits.len() as i16 - digits_after_decimal as i16 - 1;
// Remove non-significant zeroes.

2
sqlx-postgres/src/types/str.rs
View file

@ -125,7 +125,7 @@ impl Encode<'_, Postgres> for String {
impl<'r> Decode<'r, Postgres> for &'r str {
fn decode(value: PgValueRef<'r>) -> Result<Self, BoxDynError> {
Ok(value.as_str()?)
value.as_str()
}
}

2
sqlx-postgres/src/types/time/date.rs
View file

@ -24,7 +24,7 @@ impl Encode<'_, Postgres> for Date {
fn encode_by_ref(&self, buf: &mut PgArgumentBuffer) -> Result<IsNull, BoxDynError> {
// DATE is encoded as the days since epoch
let days = (*self - PG_EPOCH).whole_days() as i32;
Encode::<Postgres>::encode(&days, buf)
Encode::<Postgres>::encode(days, buf)
}
fn size_hint(&self) -> usize {

10
sqlx-postgres/src/types/time/datetime.rs
View file

@ -37,8 +37,8 @@ impl PgHasArrayType for OffsetDateTime {
impl Encode<'_, Postgres> for PrimitiveDateTime {
fn encode_by_ref(&self, buf: &mut PgArgumentBuffer) -> Result<IsNull, BoxDynError> {
// TIMESTAMP is encoded as the microseconds since the epoch
let us = (*self - PG_EPOCH.midnight()).whole_microseconds() as i64;
Encode::<Postgres>::encode(&us, buf)
let micros = (*self - PG_EPOCH.midnight()).whole_microseconds() as i64;
Encode::<Postgres>::encode(micros, buf)
}
fn size_hint(&self) -> usize {
@ -69,10 +69,10 @@ impl<'r> Decode<'r, Postgres> for PrimitiveDateTime {
// This is given for timestamptz for some reason
// Postgres already guarantees this to always be UTC
if s.contains('+') {
PrimitiveDateTime::parse(&*s, &format_description!("[year]-[month]-[day] [hour]:[minute]:[second].[subsecond][offset_hour]"))?
PrimitiveDateTime::parse(&s, &format_description!("[year]-[month]-[day] [hour]:[minute]:[second].[subsecond][offset_hour]"))?
} else {
PrimitiveDateTime::parse(
&*s,
&s,
&format_description!(
"[year]-[month]-[day] [hour]:[minute]:[second].[subsecond]"
),
@ -88,7 +88,7 @@ impl Encode<'_, Postgres> for OffsetDateTime {
let utc = self.to_offset(offset!(UTC));
let primitive = PrimitiveDateTime::new(utc.date(), utc.time());
Encode::<Postgres>::encode(&primitive, buf)
Encode::<Postgres>::encode(primitive, buf)
}
fn size_hint(&self) -> usize {

3
sqlx-postgres/src/types/time/mod.rs
View file

@ -1,5 +1,8 @@
mod date;
mod datetime;
// Parent module is named after the `time` crate, this module is named after the `TIME` SQL type.
#[allow(clippy::module_inception)]
mod time;
#[rustfmt::skip]

4
sqlx-postgres/src/types/time/time.rs
View file

@ -22,8 +22,8 @@ impl PgHasArrayType for Time {
impl Encode<'_, Postgres> for Time {
fn encode_by_ref(&self, buf: &mut PgArgumentBuffer) -> Result<IsNull, BoxDynError> {
// TIME is encoded as the microseconds since midnight
let us = (*self - Time::MIDNIGHT).whole_microseconds() as i64;
Encode::<Postgres>::encode(&us, buf)
let micros = (*self - Time::MIDNIGHT).whole_microseconds() as i64;
Encode::<Postgres>::encode(micros, buf)
}
fn size_hint(&self) -> usize {

26
sqlx-postgres/src/types/time_tz.rs
View file

@ -88,20 +88,25 @@ mod chrono {
Ok(PgTimeTz { time, offset })
}
PgValueFormat::Text => {
let s = value.as_str()?;
PgValueFormat::Text => try_parse_timetz(value.as_str()?),
}
}
}
fn try_parse_timetz(s: &str) -> Result<PgTimeTz<NaiveTime, FixedOffset>, BoxDynError> {
let mut tmp = String::with_capacity(11 + s.len());
tmp.push_str("2001-07-08 ");
tmp.push_str(s);
let dt = 'out: loop {
let mut err = None;
for fmt in &["%Y-%m-%d %H:%M:%S%.f%#z", "%Y-%m-%d %H:%M:%S%.f"] {
match DateTime::parse_from_str(&tmp, fmt) {
Ok(dt) => {
break 'out dt;
let time = dt.time();
let offset = *dt.offset();
return Ok(PgTimeTz { time, offset });
}
Err(error) => {
@ -110,16 +115,9 @@ mod chrono {
}
}
return Err(err.unwrap().into());
};
let time = dt.time();
let offset = *dt.offset();
Ok(PgTimeTz { time, offset })
}
}
}
Err(err
.expect("BUG: loop should have set `err` to `Some()` before exiting")
.into())
}
}

2
sqlx-sqlite/src/column.rs
View file

@ -19,7 +19,7 @@ impl Column for SqliteColumn {
}
fn name(&self) -> &str {
&*self.name
&self.name
}
fn type_info(&self) -> &SqliteTypeInfo {

1
sqlx-sqlite/src/connection/collation.rs
View file

@ -15,6 +15,7 @@ use crate::SqliteError;
#[derive(Clone)]
pub struct Collation {
name: Arc<str>,
#[allow(clippy::type_complexity)]
collate: Arc<dyn Fn(&str, &str) -> Ordering + Send + Sync + 'static>,
// SAFETY: these must match the concrete type of `collate`
call: unsafe extern "C" fn(

11
sqlx-sqlite/src/connection/establish.rs
View file

@ -24,6 +24,7 @@ use std::time::Duration;
// https://doc.rust-lang.org/stable/std/sync/atomic/index.html#portability
static THREAD_ID: AtomicUsize = AtomicUsize::new(0);
#[derive(Copy, Clone)]
enum SqliteLoadExtensionMode {
/// Enables only the C-API, leaving the SQL function disabled.
Enable,
@ -32,7 +33,7 @@ enum SqliteLoadExtensionMode {
}
impl SqliteLoadExtensionMode {
fn as_int(self) -> c_int {
fn to_int(self) -> c_int {
match self {
SqliteLoadExtensionMode::Enable => 1,
SqliteLoadExtensionMode::DisableAll => 0,
@ -101,13 +102,13 @@ impl EstablishParams {
}
if let Some(vfs) = options.vfs.as_deref() {
query_params.insert("vfs", &vfs);
query_params.insert("vfs", vfs);
}
if !query_params.is_empty() {
filename = format!(
"file:{}?{}",
percent_encoding::percent_encode(filename.as_bytes(), &NON_ALPHANUMERIC),
percent_encoding::percent_encode(filename.as_bytes(), NON_ALPHANUMERIC),
serde_urlencoded::to_string(&query_params).unwrap()
);
flags |= libsqlite3_sys::SQLITE_OPEN_URI;
@ -174,7 +175,7 @@ impl EstablishParams {
let status = sqlite3_db_config(
db,
SQLITE_DBCONFIG_ENABLE_LOAD_EXTENSION,
mode.as_int(),
mode.to_int(),
null::<i32>(),
);
@ -294,7 +295,7 @@ impl EstablishParams {
transaction_depth: 0,
log_settings: self.log_settings.clone(),
progress_handler_callback: None,
update_hook_callback: None
update_hook_callback: None,
})
}
}

12
sqlx-sqlite/src/connection/execute.rs
View file

@ -68,10 +68,10 @@ impl Iterator for ExecuteIter<'_> {
fn next(&mut self) -> Option<Self::Item> {
let statement = if self.goto_next {
let mut statement = match self.statement.prepare_next(self.handle) {
let statement = match self.statement.prepare_next(self.handle) {
Ok(Some(statement)) => statement,
Ok(None) => return None,
Err(e) => return Some(Err(e.into())),
Err(e) => return Some(Err(e)),
};
self.goto_next = false;
@ -83,7 +83,7 @@ impl Iterator for ExecuteIter<'_> {
statement.handle.clear_bindings();
match bind(&mut statement.handle, &self.args, self.args_used) {
match bind(statement.handle, &self.args, self.args_used) {
Ok(args_used) => self.args_used += args_used,
Err(e) => return Some(Err(e)),
}
@ -98,9 +98,9 @@ impl Iterator for ExecuteIter<'_> {
self.logger.increment_rows_returned();
Some(Ok(Either::Right(SqliteRow::current(
&statement.handle,
&statement.columns,
&statement.column_names,
statement.handle,
statement.columns,
statement.column_names,
))))
}
Ok(false) => {

8
sqlx-sqlite/src/connection/executor.rs
View file

@ -13,13 +13,15 @@ use std::future;
impl<'c> Executor<'c> for &'c mut SqliteConnection {
type Database = Sqlite;
fn fetch_many<'e, 'q: 'e, E: 'q>(
fn fetch_many<'e, 'q, E>(
self,
mut query: E,
) -> BoxStream<'e, Result<Either<SqliteQueryResult, SqliteRow>, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>,
'q: 'e,
E: 'q,
{
let sql = query.sql();
let arguments = match query.take_arguments().map_err(Error::Encode) {
@ -36,13 +38,15 @@ impl<'c> Executor<'c> for &'c mut SqliteConnection {
)
}
fn fetch_optional<'e, 'q: 'e, E: 'q>(
fn fetch_optional<'e, 'q, E>(
self,
mut query: E,
) -> BoxFuture<'e, Result<Option<SqliteRow>, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>,
'q: 'e,
E: 'q,
{
let sql = query.sql();
let arguments = match query.take_arguments().map_err(Error::Encode) {

18
sqlx-sqlite/src/connection/explain.rs
View file

@ -160,7 +160,7 @@ impl ColumnType {
}
fn map_to_datatype(&self) -> DataType {
match self {
Self::Single { datatype, .. } => datatype.clone(),
Self::Single { datatype, .. } => *datatype,
Self::Record(_) => DataType::Null, //If we're trying to coerce to a regular Datatype, we can assume a Record is invalid for the context
}
}
@ -188,7 +188,7 @@ impl core::fmt::Debug for ColumnType {
let mut column_iter = columns.iter();
if let Some(item) = column_iter.next() {
write!(f, "{:?}", item)?;
while let Some(item) = column_iter.next() {
for item in column_iter {
write!(f, ", {:?}", item)?;
}
}
@ -400,7 +400,7 @@ fn root_block_columns(
);
}
return Ok(row_info);
Ok(row_info)
}
struct Sequence(i64);
@ -544,7 +544,7 @@ impl BranchList {
std::collections::hash_map::Entry::Occupied(entry) => {
//already saw a state identical to this one, so no point in processing it
state.mem = entry.key().clone(); //replace state.mem since .entry() moved it
logger.add_result(state, BranchResult::Dedup(entry.get().clone()));
logger.add_result(state, BranchResult::Dedup(*entry.get()));
}
}
}
@ -974,7 +974,7 @@ pub(super) fn explain(
.and_then(|c| c.columns_ref(&state.mem.t, &state.mem.r))
.and_then(|cc| cc.get(&p2))
.cloned()
.unwrap_or_else(|| ColumnType::default());
.unwrap_or_default();
// insert into p3 the datatype of the col
state.mem.r.insert(p3, RegDataType::Single(value));
@ -1123,7 +1123,7 @@ pub(super) fn explain(
OP_OPEN_EPHEMERAL | OP_OPEN_AUTOINDEX | OP_SORTER_OPEN => {
//Create a new pointer which is referenced by p1
let table_info = TableDataType {
cols: IntMap::from_dense_record(&vec![ColumnType::null(); p2 as usize]),
cols: IntMap::from_elem(ColumnType::null(), p2 as usize),
is_empty: Some(true),
};
@ -1376,7 +1376,7 @@ pub(super) fn explain(
state.mem.r.insert(
p2,
RegDataType::Single(ColumnType::Single {
datatype: opcode_to_type(&opcode),
datatype: opcode_to_type(opcode),
nullable: Some(false),
}),
);
@ -1490,8 +1490,7 @@ pub(super) fn explain(
while let Some(result) = result_states.pop() {
// find the datatype info from each ResultRow execution
let mut idx = 0;
for this_col in result {
for (idx, this_col) in result.into_iter().enumerate() {
let this_type = this_col.map_to_datatype();
let this_nullable = this_col.map_to_nullable();
if output.len() == idx {
@ -1513,7 +1512,6 @@ pub(super) fn explain(
} else {
nullable[idx] = this_nullable;
}
idx += 1;
}
}

31
sqlx-sqlite/src/connection/intmap.rs
View file

@ -1,3 +1,4 @@
use std::cmp::Ordering;
use std::{fmt::Debug, hash::Hash};
/// Simplistic map implementation built on a Vec of Options (index = key)
@ -65,7 +66,7 @@ impl<V> IntMap<V> {
let item = self.0.get_mut(idx);
match item {
Some(content) => std::mem::replace(content, None),
Some(content) => content.take(),
None => None,
}
}
@ -100,7 +101,10 @@ impl<V: Default> IntMap<V> {
}
impl<V: Clone> IntMap<V> {
pub(crate) fn from_dense_record(record: &Vec<V>) -> Self {
pub(crate) fn from_elem(elem: V, len: usize) -> Self {
Self(vec![Some(elem); len])
}
pub(crate) fn from_dense_record(record: &[V]) -> Self {
Self(record.iter().cloned().map(Some).collect())
}
}
@ -139,21 +143,16 @@ impl<V: Hash> Hash for IntMap<V> {
impl<V: PartialEq> PartialEq for IntMap<V> {
fn eq(&self, other: &Self) -> bool {
if !self
.0
.iter()
.zip(other.0.iter())
.all(|(l, r)| PartialEq::eq(l, r))
{
return false;
match self.0.len().cmp(&other.0.len()) {
Ordering::Greater => {
self.0[..other.0.len()] == other.0
&& self.0[other.0.len()..].iter().all(Option::is_none)
}
if self.0.len() > other.0.len() {
self.0[other.0.len()..].iter().all(Option::is_none)
} else if self.0.len() < other.0.len() {
other.0[self.0.len()..].iter().all(Option::is_none)
} else {
true
Ordering::Less => {
other.0[..self.0.len()] == self.0
&& other.0[self.0.len()..].iter().all(Option::is_none)
}
Ordering::Equal => self.0 == other.0,
}
}
}

5
sqlx-sqlite/src/connection/mod.rs
View file

@ -4,6 +4,7 @@ use std::fmt::Write;
use std::fmt::{self, Debug, Formatter};
use std::os::raw::{c_int, c_void};
use std::panic::catch_unwind;
use std::ptr;
use std::ptr::NonNull;
use futures_core::future::BoxFuture;
@ -112,7 +113,7 @@ impl ConnectionState {
pub(crate) fn remove_progress_handler(&mut self) {
if let Some(mut handler) = self.progress_handler_callback.take() {
unsafe {
sqlite3_progress_handler(self.handle.as_ptr(), 0, None, std::ptr::null_mut());
sqlite3_progress_handler(self.handle.as_ptr(), 0, None, ptr::null_mut());
let _ = { Box::from_raw(handler.0.as_mut()) };
}
}
@ -121,7 +122,7 @@ impl ConnectionState {
pub(crate) fn remove_update_hook(&mut self) {
if let Some(mut handler) = self.update_hook_callback.take() {
unsafe {
sqlite3_update_hook(self.handle.as_ptr(), None, std::ptr::null_mut());
sqlite3_update_hook(self.handle.as_ptr(), None, ptr::null_mut());
let _ = { Box::from_raw(handler.0.as_mut()) };
}
}

34
sqlx-sqlite/src/logger.rs
View file

@ -45,9 +45,9 @@ pub struct QueryPlanLogger<'q, R: Debug + 'static, S: Debug + DebugDiff + 'stati
fn dot_escape_string(value: impl AsRef<str>) -> String {
value
.as_ref()
.replace("\\", "\\\\")
.replace("\"", "'")
.replace("\n", "\\n")
.replace('\\', r#"\\"#)
.replace('"', "'")
.replace('\n', r#"\n"#)
.to_string()
}
@ -76,7 +76,7 @@ impl<R: Debug, S: Debug + DebugDiff, P: Debug> core::fmt::Display for QueryPlanL
let mut instruction_uses: IntMap<Vec<BranchParent>> = Default::default();
for (k, state) in all_states.iter() {
let entry = instruction_uses.get_mut_or_default(&(state.program_i as i64));
entry.push(k.clone());
entry.push(*k);
}
let mut branch_children: std::collections::HashMap<BranchParent, Vec<BranchParent>> =
@ -127,27 +127,27 @@ impl<R: Debug, S: Debug + DebugDiff, P: Debug> core::fmt::Display for QueryPlanL
state_list
.entry(state_diff)
.or_default()
.push((curr_ref.clone(), Some(next_ref)));
.push((*curr_ref, Some(next_ref)));
} else {
state_list
.entry(Default::default())
.or_default()
.push((curr_ref.clone(), None));
.push((*curr_ref, None));
};
if let Some(children) = branch_children.get(curr_ref) {
for next_ref in children {
if let Some(next_state) = all_states.get(&next_ref) {
if let Some(next_state) = all_states.get(next_ref) {
let state_diff = next_state.state.diff(&curr_state.state);
if !state_diff.is_empty() {
branched_with_state.insert(next_ref.clone());
branched_with_state.insert(*next_ref);
}
state_list
.entry(state_diff)
.or_default()
.push((curr_ref.clone(), Some(next_ref.clone())));
.push((*curr_ref, Some(*next_ref)));
}
}
};
@ -176,7 +176,7 @@ impl<R: Debug, S: Debug + DebugDiff, P: Debug> core::fmt::Display for QueryPlanL
for (curr_ref, next_ref) in ref_list {
if let Some(next_ref) = next_ref {
let next_program_i = all_states
.get(&next_ref)
.get(next_ref)
.map(|s| s.program_i.to_string())
.unwrap_or_default();
@ -258,7 +258,7 @@ impl<R: Debug, S: Debug + DebugDiff, P: Debug> core::fmt::Display for QueryPlanL
let mut instruction_list: Vec<(BranchParent, &InstructionHistory<S>)> = Vec::new();
if let Some(parent) = self.branch_origins.get(&branch_id) {
if let Some(parent_state) = all_states.get(parent) {
instruction_list.push((parent.clone(), parent_state));
instruction_list.push((*parent, parent_state));
}
}
if let Some(instructions) = self.branch_operations.get(&branch_id) {
@ -278,11 +278,11 @@ impl<R: Debug, S: Debug + DebugDiff, P: Debug> core::fmt::Display for QueryPlanL
if let Some((cur_ref, _)) = instructions_iter.next() {
let mut prev_ref = cur_ref;
while let Some((cur_ref, _)) = instructions_iter.next() {
for (cur_ref, _) in instructions_iter {
if branched_with_state.contains(&cur_ref) {
write!(
writeln!(
f,
"\"b{}p{}\" -> \"b{}p{}_b{}p{}\" -> \"b{}p{}\"\n",
"\"b{}p{}\" -> \"b{}p{}_b{}p{}\" -> \"b{}p{}\"",
prev_ref.id,
prev_ref.idx,
prev_ref.id,
@ -360,7 +360,7 @@ impl<'q, R: Debug, S: Debug + DebugDiff, P: Debug> QueryPlanLogger<'q, R, S, P>
return;
}
let branch: BranchParent = BranchParent::from(state);
self.branch_origins.insert(branch.id, parent.clone());
self.branch_origins.insert(branch.id, *parent);
}
pub fn add_operation<I: Copy>(&mut self, program_i: usize, state: I)
@ -402,14 +402,14 @@ impl<'q, R: Debug, S: Debug + DebugDiff, P: Debug> QueryPlanLogger<'q, R, S, P>
return;
}
let mut summary = parse_query_summary(&self.sql);
let mut summary = parse_query_summary(self.sql);
let sql = if summary != self.sql {
summary.push_str(" …");
format!(
"\n\n{}\n",
sqlformat::format(
&self.sql,
self.sql,
&sqlformat::QueryParams::None,
sqlformat::FormatOptions::default()
)

3
sqlx-sqlite/src/migrate.rs
View file

@ -28,8 +28,7 @@ impl MigrateDatabase for Sqlite {
}
// Opening a connection to sqlite creates the database
let _ = opts
.connect()
opts.connect()
.await?
// Ensure WAL mode tempfiles are cleaned up
.close()

9
sqlx-sqlite/src/options/auto_vacuum.rs
View file

@ -1,8 +1,9 @@
use crate::error::Error;
use std::str::FromStr;
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
#[derive(Debug, Clone, Copy, PartialEq, Eq, Default)]
pub enum SqliteAutoVacuum {
#[default]
None,
Full,
Incremental,
@ -18,12 +19,6 @@ impl SqliteAutoVacuum {
}
}
impl Default for SqliteAutoVacuum {
fn default() -> Self {
SqliteAutoVacuum::None
}
}
impl FromStr for SqliteAutoVacuum {
type Err = Error;

Some files were not shown because too many files have changed in this diff Show more