All notable changes to this project will be documented in this file.
The format is based on Keep a Changelog, and this project adheres to Semantic Versioning.
- [#214] Handle percent-encoded usernames in a database URL [@jamwaffles]
-
[#216] Mark
Cursor
,Query
,QueryAs
,query::Map
, andTransaction
as#[must_use]
[@Ace4896] -
[#213] Remove matches dependency and use matches macro from std [@nrjais]
- [#212] Removed sneaky
println!
inMySqlCursor
-
[#203] Allow an empty password for MySQL
-
[#204] Regression in error reporting for invalid SQL statements on PostgreSQL
-
[#200] Fixes the incorrect handling of raw (
r#...
) fields of a struct in theFromRow
derive [@sidred]
-
sqlx::Row
now has a lifetime ('c
) tied to the database connection. In effect, this means that you cannot storeRow
s or collect them into a collection.Query
(returned fromsqlx::query()
) hasmap()
which takes a function to map from theRow
to another type to make this transition easier.In 0.2.x
let rows = sqlx::query("SELECT 1") .fetch_all(&mut conn).await?;
In 0.3.x
let values: Vec<i32> = sqlx::query("SELECT 1") .map(|row: PgRow| row.get(0)) .fetch_all(&mut conn).await?;
To assist with the above,
sqlx::query_as()
now supports querying directly into tuples (up to 9 elements) or struct types with a#[derive(FromRow)]
.// This extension trait is needed until a rust bug is fixed use sqlx::postgres::PgQueryAs; let values: Vec<(i32, bool)> = sqlx::query_as("SELECT 1, false") .fetch_all(&mut conn).await?;
-
HasSqlType<T>: Database
is nowT: Type<Database>
to mirrorEncode
andDecode
-
Query::fetch
(returned fromquery()
) now returns a newCursor
type.Cursor
is a Stream-like type where the item type borrows into the stream (which itself borrows from connection). This means that usingquery().fetch()
you can now stream directly from the database with zero-copy and zero-allocation. -
Remove
PgTypeInfo::with_oid
and replace withPgTypeInfo::with_name
-
Results from the database are now zero-copy and no allocation beyond a shared read buffer for the TCP stream ( in other words, almost no per-query allocation ). Bind arguments still do allocate a buffer per query.
-
[#129] Add support for SQLite. Generated code should be very close to normal use of the C API.
- Adds
Sqlite
,SqliteConnection
,SqlitePool
, and other supporting types
- Adds
-
[#97] [#134] Add support for user-defined types. [@Freax13]
-
Rust-only domain types or transparent wrappers around SQL types. These may be used transparently inplace of the SQL type.
#[derive(sqlx::Type)] #[repr(transparent)] struct Meters(i32);
-
Enumerations may be defined in Rust and can match SQL by integer discriminant or variant name.
#[derive(sqlx::Type)] #[repr(i32)] // Expects a INT in SQL enum Color { Red = 1, Green = 2, Blue = 3 }
#[derive(sqlx::Type)] #[sqlx(rename = "TEXT")] // May also be the name of a user defined enum type #[sqlx(rename_all = "lowercase")] // similar to serde rename_all enum Color { Red, Green, Blue } // expects 'red', 'green', or 'blue'
-
Postgres further supports user-defined composite types.
#[derive(sqlx::Type)] #[sqlx(rename = "interface_type")] struct InterfaceType { name: String, supplier_id: i32, price: f64 }
-
-
[#98] [#131] Add support for asynchronous notifications in Postgres (
LISTEN
/NOTIFY
). [@thedodd]-
Supports automatic reconnection on connection failure.
-
PgListener
implementsExecutor
and may be used to execute queries. Be careful however as if the intent is to handle and process messages rapidly you don't want to be tying up the connection for too long. Messages received during queries are buffered and will be delivered on the next call torecv()
.
let mut listener = PgListener::new(DATABASE_URL).await?; listener.listen("topic").await?; loop { let message = listener.recv().await?; println!("payload = {}", message.payload); }
-
-
Add unchecked variants of the query macros. These will still verify the SQL for syntactic and semantic correctness with the current database but they will not check the input or output types.
This is intended as a temporary solution until
query_as!
is able to support user defined types.query_as_unchecked!
query_file_as_unchecked!
-
Add support for many more types in Postgres
JSON
,JSONB
[@oeb25]INET
,CIDR
[@PoiScript]- Arrays [@oeb25]
- Composites ( Rust tuples or structs with a
#[derive(Type)]
) NUMERIC
[@abonander]OID
(u32
)"CHAR"
(i8
)TIMESTAMP
,TIMESTAMPTZ
, etc. with thetime
crate [@utter-step]- Enumerations ( Rust enums with a
#[derive(Type)]
) [@Freax13]
-
Query
(andQueryAs
; returned fromquery()
,query_as()
,query!()
, andquery_as!()
) now will accept both&mut Connection
or&Pool
where as in 0.2.x they required&mut &Pool
. -
Executor
now takes any value that implementsExecute
as a query.Execute
is implemented forQuery
andQueryAs
to mean exactly what they've meant so far, a prepared SQL query. However,Execute
is also implemented for just&str
which now performs a raw or unprepared SQL query. You can further use this to fetchRow
s from the database though it is not as efficient as the prepared API (notably Postgres and MySQL send data back in TEXT mode as opposed to in BINARY mode).use sqlx::Executor; // Set the time zone parameter conn.execute("SET TIME ZONE LOCAL;").await // Demonstrate two queries at once with the raw API let mut cursor = conn.fetch("SELECT 1; SELECT 2"); let row = cursor.next().await?.unwrap(); let value: i32 = row.get(0); // 1 let row = cursor.next().await?.unwrap(); let value: i32 = row.get(0); // 2
-
Query
(returned fromquery()
) no longer hasfetch_one
,fetch_optional
, orfetch_all
. You must map the row usingmap()
and then you will have aquery::Map
value that has the former methods available.let values: Vec<i32> = sqlx::query("SELECT 1") .map(|row: PgRow| row.get(0)) .fetch_all(&mut conn).await?;
-
[#62] [#130] [#135] Remove explicit set of
IntervalStyle
. Allow usage of SQLx for CockroachDB and potentially PgBouncer. [@bmisiak] -
[#108] Allow nullable and borrowed values to be used as arguments in
query!
andquery_as!
. For example, where the column would resolve toString
in Rust (TEXT, VARCHAR, etc.), you may now useOption<String>
,Option<&str>
, or&str
instead. [@abonander] -
[#108] Make unknown type errors far more informative. As an example, trying to
SELECT
aDATE
column will now try and tell you about thechrono
feature. [@abonander]optional feature `chrono` required for type DATE of column #1 ("now")
-
[#125] [#126] Fix statement execution in MySQL if it contains NULL statement values [@repnop]
-
[#105] [#109] Allow trailing commas in query macros [@timmythetiny]
-
Fix decoding of Rows containing NULLs in Postgres #104
-
After a large review and some battle testing by @ianthetechie of the
Pool
, a live leaking issue was found. This has now been fixed by @abonander in #84 which included refactoring to make the pool internals less brittle (using RAII instead of manual work is one example) and to help any future contributors when changing the pool internals. -
Passwords are now being precent decoding before being presented to the server [@repnop]
-
[@100] Fix
FLOAT
andDOUBLE
decoding in MySQL
-
[#72] Add
PgTypeInfo::with_oid
to allow simple construction ofPgTypeInfo
which enablesHasSqlType
to be implemented by downstream consumers of SQLx [@jplatte] -
[#96] Add support for returning columns from
query!
with a name of a rust keyword by using raw identifiers [@yaahc] -
[#71] Implement derives for
Encode
andDecode
. This is the first step to supporting custom types in SQLx. [@Freax13]
- Fix decoding of Rows containing NULLs in MySQL (and add an integration test so this doesn't break again)
- Fix
query!
when used on a query that does not return results
-
Fix stall when requesting TLS from a Postgres server that explicitly does not support TLS (such as postgres running inside docker) [@abonander]
-
[#66] Declare used features for
tokio
insqlx-macros
explicitly
- [#64, #65] Fix decoding of Rows containing NULLs in MySQL [@danielakhterov]
- [#55] Use a shared tokio runtime for the
query!
macro compile-time execution (under theruntime-tokio
feature) [@udoprog]
-
Support Tokio through an optional
runtime-tokio
feature. -
Support SQL transactions. You may now use the
begin()
function onPool
orConnection
to start a new SQL transaction. This returnssqlx::Transaction
which willROLLBACK
onDrop
or can be explicitlyCOMMIT
usingcommit()
. -
Support TLS connections.
-
Support for
SCRAM-SHA-256
authentication in Postgres #37 @danielakhterov -
Implement
Debug
for Pool #42 @prettynatty
-
Support for Authentication in MySQL 5+ including the newer authentication schemes now default in MySQL 8:
mysql_native_password
,sha256_password
, andcaching_sha2_password
. -
Chrono
support for MySQL was only partially implemented (was missingNaiveTime
andDateTime<Utc>
). -
Vec<u8>
(and[u8]
) support for MySQL (BLOB
) and Postgres (BYTEA
).