Commit graph

625 commits

Author SHA1 Message Date
Ryan Leckey
72c1f52caf
style(core): apply clippy suggestions 2020-05-30 18:00:21 -07:00
Ryan Leckey
e08f05b879
feat: re-introduce error downcasting 2020-05-30 17:51:56 -07:00
Ryan Leckey
e5b6047009
feat: introduce docker-compose based testing for running locally against many database combinations 2020-05-30 17:51:55 -07:00
Ryan Leckey
afd831b0d3
feat: re-introduce Pool::begin and add Pool::try_begin to match Pool::try_acquire 2020-05-30 17:51:55 -07:00
Ryan Leckey
0a04abdb3e
feat: Pool is now generic over Database, as opposed to Connection
this fixes an unfortunate interaction with HRTBs where the compiler would
produce infinitely nested PoolConnection<PoolConnection<....
2020-05-30 17:51:55 -07:00
Ryan Leckey
cf7606be1b
fix: Transaction now to rollbacks on drop (again) 2020-05-30 17:51:55 -07:00
Ryan Leckey
bb3b571a57
fix: tweak lifetimes in Executor to limit the scope for the borrow on the query to the single execution 2020-05-30 17:51:55 -07:00
Ryan Leckey
cc9d443434
feat: re-introduce Transaction
* Transaction now wraps `&mut Connection` instead of `Connection`
2020-05-30 17:51:55 -07:00
Ryan Leckey
9d2a0141cb
feat: introduce IntoArguments, query_with, query_as_with, and query_scalar_with 2020-05-30 17:51:55 -07:00
Ryan Leckey
88532ffc28
refactor: clean up warnings 2020-05-30 17:51:49 -07:00
Ryan Leckey
a54b1267f6
refactor(macros): adapt to the 0.4.x core refactor 2020-05-30 17:51:49 -07:00
Ryan Leckey
eaa7fba9d4
refactor(postgres): adapt to the 0.4.x core refactor 2020-05-30 17:49:30 -07:00
Ryan Leckey
2966b655fc
refactor(mysql): adapt to the 0.4.x core refactor 2020-05-30 17:48:10 -07:00
Ryan Leckey
37a69e0ac3
refactor(sqlite): adapt to the 0.4.x core refactor
* massive (~20x) performance improvement
2020-05-30 16:09:50 -07:00
Ryan Leckey
757a930e21
refactor(core): remove the HRTB (higher rank trait bound) on Row in the aim of improving ergonomics
* removes the lifetime from Row

 * removes MySqlQueryAs, SqliteQueryAs, etc. (no longer needed)

 * introduce query_scalar

 * introduce Decode::accepts to allow overriding runtime type checking
   per-type (replaces TypeInfo::compatible)

 * introduce Encode::produces to allow overriding the encoded type per-value

 * adds a lifetime to Arguments (and introduce the HRTB HasArguments)
   to support zero-copy encoding with SQLite

 * renames Database::RawBuffer to HasArguments::ArgumentBuffer

 * introduce Connect::connect_with to provide an ConnectOptions type
   explicitly to opt-out of connection string parsing

 * introduce Value and ValueRef traits to allow decoding-deferred
   extraction of values from Rows

 * introduce Encode::encode_by_ref and change Encode::encode to take
   by-value to try and re-use memory where possible

 * use thiserror to generate sqlx::Error

 * [!] temporarily removes query logging

 * [!] temporarily removes transactions
2020-05-30 16:09:08 -07:00
Austin Bonander
6913695588 add support for building in "decoupled" mode 2020-05-30 16:02:37 -07:00
吴翱翔
77cdafe08a Fix a misspelling in MySQL types document 2020-05-15 12:46:35 -07:00
Ryan Leckey
cbccd68963
chore: prepare v0.3.5 2020-05-06 03:30:35 -07:00
meh
7b1cc7fd09 Derive Serialize and Deserialize for Json 2020-05-06 00:13:19 -07:00
Austin Bonander
c285e28670 fix and test handling of 0 for BigDecimal in Postgres/MySQL
closes #283
2020-04-28 11:54:41 -07:00
Peter Maatman
4122a3dbd9 mysql: Advance buffer to comply with protocol
Fixes #254
2020-04-27 16:47:38 -07:00
Hasan Ali
3e2ed00b60 Drop all statements before closing sqlite connection 2020-04-27 10:20:57 -07:00
Josh Holmer
581bcf0ceb Extract slow query threshold to constant 2020-04-23 14:09:59 -07:00
Josh Holmer
627d8292f8 Log queries from sqlx::query
This will make logged queries show
as from `sqlx::query` instead of `sqlx::db_name::executor`.

Followup to #268
2020-04-23 14:09:59 -07:00
Josh Holmer
f73149a90f Format SQL queries when printing them to the logs
Before, the query would be formatted equivalent to the input string:

```
[2020-04-18T23:47:32Z DEBUG sqlx_core::postgres::executor] SELECT id, queue, ..., elapsed: 2.320µs

        SELECT id, queue, payload, status, priority, created_at, updated_at
    FROM jobs
    WHERE status = $1
    ORDER BY priority ASC, created_at ASC

```

After, the query is formatted cleanly and consistently:

```
[2020-04-19T00:30:18Z DEBUG sqlx_core::postgres::executor] SELECT id, queue, ..., elapsed: 2.280µs

    SELECT
      id,
      queue,
      payload,
      status,
      priority,
      created_at,
      updated_at
    FROM
      jobs
    WHERE
      status = $1
    ORDER BY
      priority ASC,
      created_at ASC

```

This uses the `sqlformat` crate, which was ported from the
Javascript `sql-formatter-plus` library specifically for this purpose.
2020-04-19 16:11:50 -07:00
Ryan Leckey
1cdfb8507c fix: remove the clone on Encode for JsonValue 2020-04-19 16:05:37 -07:00
Peter Maatman
1b04829c46 json: Refactor Encode/Decode for serde values to be generic for DB
Since the implementation of Encode and Decode for both mysql and
postgres on serde's Value and RawValue were practically the same they
were moved to the generic json module.
2020-04-19 15:58:47 -07:00
Peter Maatman
30d13174ea mysql: Add JSON support 2020-04-19 15:58:47 -07:00
Felix Wiedemann
57f52ffbc4 postgres: Use $USER as default for the username 2020-04-18 14:31:31 -07:00
Felix Wiedemann
f3fe41ebdb postgres: Use username as default for database name 2020-04-18 14:31:31 -07:00
Felix Wiedemann
a2673f7880 postgres: Add support for postgres:///?host=... connection strings 2020-04-18 14:31:31 -07:00
Felix Wiedemann
fc78f15ebf postgres: Add support for non-default socket paths 2020-04-18 14:31:31 -07:00
Felix Wiedemann
5628658d3f postgres: Add unix domain socket support 2020-04-18 14:31:31 -07:00
Felix Wiedemann
49f15713d6 Move empty host handling to the DB specific code 2020-04-18 14:31:31 -07:00
Josh Holmer
16229fd0ad Add basic query logging
Prints each query performed at DEBUG level,
along with a timing of how long the query took
to execute.

Slow queries will be printed at WARN level.
Currently the slow query threshold is
hardcoded to 1 second.
2020-04-17 22:49:33 -07:00
George Kaplan
7df6d4dbcf undo URL percent-encoding for SQLite connection strings 2020-04-17 18:23:33 -07:00
meh
2fb38dd0c1 Derive all traits and impl Deref and AsRef for types::Json 2020-04-16 11:00:31 -07:00
Austin Bonander
80eb2cc7d2 make the stream returned from Map::fetch() Unpin
closes #244
2020-04-11 03:04:21 -07:00
Ryan Leckey
90fd35745c Prepare v0.3.4 2020-04-10 15:56:13 -07:00
xiaopengli89
5711e1cc94 refactor: mysql decimal value is just ascii str 2020-04-10 15:35:58 -07:00
xiaopengli89
229635771a fix: test 2020-04-10 15:35:58 -07:00
xiaopengli89
771d423c6f fix: change u8::MAX to std::u8::MAX 2020-04-10 15:35:58 -07:00
xiaopengli89
401ffd19e6 add test_encode_decimal, test_decode_decimal 2020-04-10 15:35:58 -07:00
xiaopengli89
b354ed430d implement DECIMAL type support for mysql 2020-04-10 15:35:58 -07:00
Ryan Leckey
d360f682f8 fix(postgres): guarantee the type name on a PgTypeInfo to always be set
fixes #241
2020-04-10 13:37:08 -07:00
Ryan Leckey
cd6735b5d7 fix(sqlite): handle empty statements, fixes #231 2020-04-08 02:13:37 -07:00
Ryan Leckey
72bd933e41 add MapRow impls; closes #228 2020-04-08 01:24:57 -07:00
Kristy Brambila
0e61642165 Make postgres type name resolution case-insensitive 2020-04-08 01:22:37 -07:00
kosyak
6c9241a3a9 Fixed types of variables that interact with libsqlite3 2020-04-07 04:10:47 -07:00
Ryan Leckey
e7ace2adc7 Prepare v0.3.3 2020-04-01 18:24:08 -07:00
Ryan Leckey
2a9774d84f use cow::borrowed to remove a minor allocation in postgres/startup
refs #214
2020-03-31 21:41:29 -07:00
Ryan Leckey
3a997f06ab
Merge pull request #214 from jamwaffles/encoded-connection-string
Decode username on read
2020-03-31 21:38:33 -07:00
James Waples
f05f6bedd9 Decode username on read 2020-03-31 23:03:17 +01:00
Ryan Leckey
283f0ef6d8
Merge pull request #216 from Ace4896/must-use-types
Mark several types as #[must_use]
2020-03-31 11:49:05 -07:00
Jon Pacheco
ccc2bfa0a6 Mark several types as #[must_use] 2020-03-31 14:39:29 +01:00
Neeraj Jaiswal
c29fc5cccd Remove matches dependency and use matches macro from std 2020-03-31 18:01:06 +05:30
Ryan Leckey
a9fc05378e Prepare v0.3.2 2020-03-31 03:02:01 -07:00
Ryan Leckey
371e843bb2 mysql: remove random println 2020-03-31 03:00:31 -07:00
Ryan Leckey
a84e1f6626 Prepare v0.3.1 2020-03-30 18:53:03 -07:00
Ryan Leckey
b65602d842 postgres: remove unused import 2020-03-30 18:52:52 -07:00
Ryan Leckey
d820763bb9 mysql: infer empty password to mean no password 2020-03-30 18:42:25 -07:00
Ryan Leckey
d3eb9c7800 postgres: use PgStream::receive over PgStream::read to handle errors
* PgStream::read should probably be named better; maybe PgStream::raw_receive

Fixes #203
2020-03-30 18:38:31 -07:00
Ryan Leckey
bbbc1811ce postgres: tweak DataRow::read 2020-03-30 18:31:05 -07:00
Ryan Leckey
670265f103 docs: fix link to db types 2020-03-29 16:34:05 -07:00
Ryan Leckey
fc3d06bf9b Prepare v0.3.0 2020-03-29 16:27:41 -07:00
Ryan Leckey
6de52567d7 docs: fix link to db types 2020-03-29 16:00:51 -07:00
Ryan Leckey
4ec9e9fce2 mysql: remove MySqlTypeInfo from mysql::types 2020-03-29 16:00:02 -07:00
Ryan Leckey
4b9a615b32 sqlite: remove SqliteTypeInfo from sqlite::types 2020-03-29 15:57:59 -07:00
Ryan Leckey
b8537d0a87 sqlite: condense allow(unsafe_code) 2020-03-29 15:55:09 -07:00
Ryan Leckey
2b06386bf1 sqlite: remove two unused imports 2020-03-29 15:53:04 -07:00
Ryan Leckey
b6d87a4cc7 require Rows to be Sync 2020-03-29 15:52:49 -07:00
Austin Bonander
73a9155b46 fix import of from_utf8_unchecked() 2020-03-28 17:50:27 -07:00
Austin Bonander
4ffa7f0e01 SQLite: implement column nullability checking 2020-03-28 17:50:27 -07:00
Austin Bonander
fe00c0d619 sqlite/statement.rs: lift #[allow(unsafe_code)] to module 2020-03-28 17:50:27 -07:00
Austin Bonander
6fde5a2579 implement nullability on macro output, test postgres 2020-03-28 17:50:27 -07:00
Oliver Bøving
bcb3959379
Add array of uuid, chrono, time, bigdecimal, and ipnetwork as well as JsonValue to query macro (#154)
* Add array of uuid, chrono, time, bigdecimal, and ipnetwork to query macro

* Comment out tests for arrays of BigDecimal

Currently arrays of BigDecimal doesn't in query macros compile.
As all of the other types work just fine, BigDecimal is simply omitted.

* Add serde_json::Value to query macros

This also adds serde_json as an optional dependency to sqlx_macros along
side a new json feature flag.
2020-03-28 17:28:47 -07:00
Ryan Leckey
dddaefec41 postgres: capitalize the W in handling the WHERE field for notice
Fixes #120
2020-03-27 16:43:15 -07:00
Ryan Leckey
a2d82d0ac1 Add Row::get_unchecked and Row::try_get_unchecked 2020-03-27 16:11:28 -07:00
Austin Bonander
e594a7fdca Postgres: don't cache failed statement 2020-03-27 15:54:28 -07:00
Ryan Leckey
3103d50be8 postgres: implement PgTypeInfo::with_name
- remove PgTypeInfo::with_oid
 - use a new PgRawBuffer type instead of Vec<u8> for encoding
2020-03-26 19:29:49 -07:00
Ryan Leckey
2409c2b042 postgres: indicate that we do not support CITEXT right now 2020-03-26 19:16:54 -07:00
Austin Bonander
e99a863288 remove now-unused imports and reformat 2020-03-25 21:37:11 -07:00
Austin Bonander
6e3fa49ad5 add unit tests for DatabaseError downcasting 2020-03-25 18:26:57 -07:00
Austin Bonander
673f133cab un-generify Error and support downcasting in DatabaseError 2020-03-25 18:13:56 -07:00
Ryan Leckey
a90ff10a27 Prepare v0.3.0-alpha.2 2020-03-25 04:58:22 -07:00
Ryan Leckey
41608c3f60 rename {DB}Error -> {DB}DatabaseError 2020-03-25 04:50:27 -07:00
Ryan Leckey
2274b69556 postgres: support "CHAR" and OID 2020-03-25 04:46:17 -07:00
Ryan Leckey
6049f976f9 opt out of compatible type check for null values 2020-03-25 04:25:38 -07:00
Ryan Leckey
7ab772ea80 postgres: simplify JSON support to just Json<T> 2020-03-25 04:20:35 -07:00
Ryan Leckey
8454fa4e96 fix tests and ensure all types are being tested in CI 2020-03-25 04:06:14 -07:00
Ryan Leckey
2f6bab396a Add PartialEq for PgTypeInfo and SqliteTypeInfo 2020-03-25 03:59:29 -07:00
Ryan Leckey
ad2cf1676f mysql: tweak type equivalence rules to try and support both rust best practices but still be compatible with the loose types of mysql 2020-03-25 03:56:39 -07:00
Ryan Leckey
50928b06b8 mysql: implement type compatible checks 2020-03-25 03:24:43 -07:00
Ryan Leckey
985d62009c sqlite: adjust for recent changes with RawValue 2020-03-25 02:37:10 -07:00
Ryan Leckey
fbd1a0435f postgres: support NAME and UNKNOWN types (compatible to TEXT) 2020-03-25 02:28:30 -07:00
Ryan Leckey
6ebd5c8c1e postgres: test type compatibility for record fields 2020-03-25 02:28:10 -07:00
Ryan Leckey
129efcd367 implement a runtime type compatibility check before decoding values 2020-03-25 02:07:17 -07:00
Ryan Leckey
1dc582edd0 postgres: have PgValue remember its type OID
this is in preparation of doing type compatibility checks
2020-03-25 01:46:13 -07:00
Ryan Leckey
918a797581 move HasX types into the module where X is 2020-03-25 01:44:00 -07:00
Ryan Leckey
63aa3e8f0f add support for VARCHAR and BPCHAR in postgres 2020-03-24 12:49:52 -07:00
Ryan Leckey
dcea3f0586 fix FromRow derive to take &Row 2020-03-24 03:08:58 -07:00
Ryan Leckey
aa1cb24de9 remove DecodeOwned 2020-03-24 03:03:04 -07:00
Ryan Leckey
fa4138b25c add docs to explain the SQL <-> Rust mapping 2020-03-24 02:56:52 -07:00
Ryan Leckey
43a72657f9 add a hack so bigdecimal can be the package name and the feature name 2020-03-24 02:56:14 -07:00
Ryan Leckey
f2ca42256b Add more documentation for Connection and Transaction 2020-03-24 02:12:42 -07:00
Ryan Leckey
412f7125fb document Cursor 2020-03-24 01:53:56 -07:00
Ryan Leckey
1940b685d3 fix warnings from rustdoc 2020-03-24 01:36:17 -07:00
Ryan Leckey
792acdd554 audit Row, FromRow, and ColumnIndex
* tweak FromRow to accept Row by reference, should make it easier to compose FromRow impls
 * rename ColumnIndex::resolve to ColumnIndex::index
 * document behaviors
2020-03-24 01:24:10 -07:00
Ryan Leckey
0182ce92f2 make sqlx_core::runtime private and add a runtime module to sqlx-macros 2020-03-24 01:19:03 -07:00
Ryan Leckey
ba86bc5555 Tweak doc on Cursor::next 2020-03-23 21:22:09 -07:00
Ryan Leckey
a0bf61cc4a Declare ColumnIndex over Row instead of over Database 2020-03-23 21:21:59 -07:00
Ryan Leckey
cb2e3220e0 simplify lifetimes on Row 2020-03-21 03:25:17 -07:00
Ryan Leckey
200d534b8a Fix time/chrono decode tests 2020-03-21 03:01:23 -07:00
Ryan Leckey
0ef1ef3c4f time: we need std feature 2020-03-21 02:42:32 -07:00
Ryan Leckey
db543f8391 clean up Time impl, impl for text modes 2020-03-21 02:34:21 -07:00
Ryan Leckey
4a98a51a19 Merge remote-tracking branch 'utter-step/time-rs' 2020-03-21 01:25:00 -07:00
Ryan Leckey
05d8ac2747 Finish up JSON/JSONB support for Postgres
* implement for &serde_json::RawValue

 * sqlx::types::Json<T> is a common type that all JSON-compatible databases can implement for,
   postgres implements Json<T> as JSONB

 * sqlx::postgres::types::PgJson<T> resolves to JSON

 * sqlx::postgres::types::PgJsonB<T> resolves to JSONB
2020-03-21 01:16:34 -07:00
Oliver Bøving
b7e53e885a First draft of JSON/JSONB support for postgres
This introduces two new wrapper types `Json` and `Jsonb`, currently
exported by `sqlx::postgres::{Json, Jsonb}` and adds serde and
serde_json as optional dependencies, under the feature flag `json`.
Wrapping types in `Json[b]` that implement `serde::Deserialize` and
`serde::Serialize` allows them to be decoded and encoded respectivly.
2020-03-20 23:59:25 -07:00
Daniel Akhterov
cbdc1bbfb2 Refactor the error to be generic over database 2020-03-20 23:51:45 -07:00
Ryan Leckey
f86f80d8b9 mysql: ping now follows the normal stream lifecycle
fixes test introduced by #142

Co-authored-by: Daniel Akhterov <daniel@launchbadge.com>
2020-03-20 20:47:30 -07:00
Ryan Leckey
ec27b65b26 postgres: change types in macros
Co-authored-by: Oliver Bøving <oliverboving@gmail.com>
2020-03-20 20:07:52 -07:00
Ryan Leckey
e42a995fd9 Extract a PgSequenceDecoder from ArrayDecoder and RecordDecoder and improve to support mutual nesting 2020-03-20 19:56:25 -07:00
Ryan Leckey
13997ce957 Change HasSqlType to Type 2020-03-20 19:55:47 -07:00
Ryan Leckey
9973fa6357 Add decode_err! to help with formatted decode error generation 2020-03-20 19:55:00 -07:00
Ryan Leckey
24d62dd464 Add DecodeOwned to help with trait bounds on owned data 2020-03-20 19:54:44 -07:00
Ryan Leckey
f562e919b7 Merge branch '1d-array-pg-support' of https://github.com/oeb25/sqlx into oeb25-1d-array-pg-support 2020-03-20 10:11:02 -07:00
Ryan Leckey
50c3e5fefb
Merge pull request #138 from PoiScript/master
postgres: ipnetwork support
2020-03-20 09:54:43 -07:00
Ryan Leckey
a017150890 postgres: tls: accept invalid certificates and mismatched hostnames under "prefer" 2020-03-20 09:47:18 -07:00
PoiScript
fbbae16a74 update decoding and encoding 2020-03-20 11:10:36 +08:00
PoiScript
3014ab4750 fix typo in Cargo.toml 2020-03-20 10:51:47 +08:00
PoiScript
7ab76ba84e make inet and cidr compatible 2020-03-20 10:19:14 +08:00
PoiScript
c9cca27e65 rename feature gate to ipnetwork 2020-03-20 10:19:14 +08:00
PoiScript
060c5d2b66 postgres: ipnetwork support 2020-03-19 18:21:09 +08:00
Ryan Leckey
9be1512833 mysql: use double literals in test 2020-03-18 23:16:56 -07:00
Ryan Leckey
2a8906d1e5 add more documentation 2020-03-18 22:46:44 -07:00
Ryan Leckey
1fc18460b0 transaction: document, test, and fix operation of nested transactions 2020-03-18 22:46:44 -07:00
Ryan Leckey
829f37793a Re-export PgRecordEncoder and PgRecordDecoder 2020-03-18 22:11:02 -07:00
Ryan Leckey
5809f8687c Merge remote-tracking branch 'origin/ab/bigdecimal' 2020-03-18 22:09:27 -07:00
Ryan Leckey
dfb313f0c6 Add Postgres <-> Rust type documentation 2020-03-18 22:08:32 -07:00
Ryan Leckey
cb67ed0300 Make PgTypeInfo::oid doc(hidden) 2020-03-18 22:08:18 -07:00
Austin Bonander
33677e86a8 move PgNumeric[Sign], PgRecord[Encoder,Decoder] to hidden postgres::types::raw
fix errors
2020-03-18 19:36:54 -07:00
Austin Bonander
7ffec2fef8 remove .expect() in impl TryFrom<PgNumeric> for BigDecimal 2020-03-18 19:12:14 -07:00
Austin Bonander
979c5cc944 remove unnecessary comment and update Cargo.lock 2020-03-18 19:09:10 -07:00
Austin Bonander
3a43e939e3 refactor PgNumeric so NaN can't be misinterpreted, document types 2020-03-18 19:06:14 -07:00
Austin Bonander
b7aabaa0ec numeric/bigdecimal modules: fix warnings 2020-03-18 19:06:14 -07:00
Austin Bonander
3cb42def3b macros: add support for Postgres + BigDecimal 2020-03-18 19:06:14 -07:00
Austin Bonander
94c40b3eb7 Postgres: implement numeric and BigDecimal support 2020-03-18 19:06:14 -07:00
Ryan Leckey
06be59f7f0 Remove MaybeOwned 2020-03-18 17:08:44 -07:00
Ryan Leckey
d1af2fe1b0 Prepare v0.3.0-alpha.1 2020-03-18 16:58:42 -07:00
Ryan Leckey
9d9d2bbfd4 Update dependencies 2020-03-18 16:56:24 -07:00
Ryan Leckey
6f4c478fb7 sqlite: fix NULL handling 2020-03-18 16:52:27 -07:00
Ryan Leckey
2f78ce094c mysql: use correct default port 2020-03-17 22:02:01 -07:00
Ryan Leckey
d380f4b4a8 remove is_null_type and use Option<TypeInfo> 2020-03-17 21:43:41 -07:00
Ryan Leckey
927e2b1586 describe: fix Debug of Column 2020-03-17 21:34:12 -07:00
Ryan Leckey
b04f2cbd4d sqlite: fix detection of INT and CHAR types 2020-03-17 21:34:01 -07:00
Austin Bonander
6cea7e2c1b macros: add proper test for sqlite using database file 2020-03-17 21:10:19 -07:00
Austin Bonander
8328e07c97 macros + sqlite: fix error for null-typed columns 2020-03-17 21:10:19 -07:00
Ryan Leckey
2a76123bc3
Merge pull request #134 from launchbadge/derives
Add derives to support custom types
2020-03-17 20:04:19 -07:00
Ryan Leckey
21059620dc mysql: support understanding ENUM as TEXT 2020-03-17 19:26:31 -07:00
Ryan Leckey
c1e6b2045c postgres: support null in a record 2020-03-17 19:26:15 -07:00
Brian Misiak
459828ee3d
postgres: remove IntervalStyle to fix #130
Support more server versions, including CockroachDB, which only supports the `postgres` style.
2020-03-17 17:55:27 -07:00
Ryan Leckey
100602187f memo: add more documentation to the database module 2020-03-17 16:33:44 -07:00
Ryan Leckey
602e61ab27 postgres: add support for decoding anonymous tuples and more fully test encoding/decoding records 2020-03-17 02:47:37 -07:00
Ryan Leckey
4e7b1b51e0 sqlite: handle encoding nulls 2020-03-17 01:13:32 -07:00
Ryan Leckey
a5d17eab00 add derive(Debug) for PgValue 2020-03-17 01:13:15 -07:00
Ryan Leckey
ced6713f57 add trailing newline 2020-03-17 01:11:15 -07:00
Tom Dohrmann
8841f83e68 removed unused imports 2020-03-16 22:58:31 -07:00
Tom Dohrmann
4cd179d42b move decode_struct_field and encode_struct_field to sqlx-core 2020-03-16 22:58:31 -07:00
Tom Dohrmann
c3aeb275c2 add derive macros for weak & strong enums and structs 2020-03-16 22:58:25 -07:00
Ryan Leckey
ada57fa566 postgres depends on Sink from futures 2020-03-16 22:55:25 -07:00
Ryan Leckey
e0ca521889 cursor: for now, add #[doc(hidden)] to from_connection and from_pool as we look for ways to remove them 2020-03-16 22:51:55 -07:00
Ryan Leckey
d8f3953d9d depend on std feature in futures-channel 2020-03-16 20:32:36 -07:00
Ryan Leckey
4869f48f84 sqlite: don't leak on connection failure 2020-03-16 20:30:28 -07:00
Ryan Leckey
48714e8ea9 Remove unused import in postgres/listen.rs 2020-03-16 20:00:36 -07:00
Ryan Leckey
0e3eb7ce39 postgres: listen: go back to Vec<String> for channels 2020-03-16 19:54:38 -07:00
Ryan Leckey
57d414f15c sqlite: fix impl of DatabaseError 2020-03-16 19:54:24 -07:00
Ryan Leckey
e99e80cf94 listen: merge PgListener and PgPoolListener; allow PgListener to be used as an Executor; allow channels to be adjusted at run-time 2020-03-16 18:35:37 -07:00
Ryan Leckey
ed9d6c3b62 pool: handle reconnects during "boot" 2020-03-16 18:34:09 -07:00
Ryan Leckey
f677748a3b postgres: Add lifetime to NotificationResponse 2020-03-16 18:31:09 -07:00
Ryan Leckey
b80080a95b postgres: Stream::read -> Stream::receive and extract "just reading" to Stream::read 2020-03-16 18:30:45 -07:00
Ryan Leckey
0ecacfaf1d io: forward lifetime properly in Buf trait 2020-03-16 18:29:54 -07:00
Ryan Leckey
1d0100b35d Add DatabaseError::code 2020-03-16 18:29:41 -07:00
Ryan Leckey
5cb0d9d9cc connection: remove unused import for MaybeOwned 2020-03-16 18:27:22 -07:00
Ryan Leckey
12e250b52c Inline MaybeOwned in ConnectionSource and add another variant to store owned or ref connections 2020-03-15 02:58:41 -07:00
Ryan Leckey
4419aea619 update postgres/listen.rs for internal changes 2020-03-15 02:17:14 -07:00
Anthony Dodd
3db54dd724 Remove the Drop impl for PgPoolListener.
This is being removed as it was causing undesired behavior under some
contexts.
2020-03-15 02:17:14 -07:00
Anthony Dodd
82923a1aaa Update stream impls.
The basic PgListener stream impl now yields `Result<PgNotification>`
elements without an `Option` in the result. The option condition
originally represented the closure of the underlying connection. Now
such conditions will terminate the stream, as one would expect. The
`PgListener.recv()` method signature has not been changed.

PgPoolListener has also been updated. The interfaces on this struct will
never yield an inner `Option` as it will instead acquire a new
connection and continue its work. Both the stream impl & the `recv`
method have received an update to their signatures.
2020-03-15 02:17:14 -07:00
Anthony Dodd
608556f91a Impl Drop for PgPoolListener & add to exports. 2020-03-15 02:17:14 -07:00
Anthony Dodd
ae7e15cbe3 Added demo program to show use of LISTEN/NOTIFY. 2020-03-15 02:17:14 -07:00
Anthony Dodd
a0da99e128 A good bit of refactoring.
Broke up PgListener into two types. PgListener for basic one-off
connections, and PgPoolListener for the listener created from the
PgPool.

The API is a bit more clear now with this change in terms of reconnect
behavior and the like.

Update `fn stream` to be `fn into_stream`, as that nomenclature is a bit
more normative in the Rust ecosystem.
2020-03-15 02:17:14 -07:00
Anthony Dodd
f83180861b Impl a few features & refactor some code based on design discussion.
Extension traits are now being used for PgConnection, PgPoolConnection &
PgPool for listen/notify functionality. Only two extension traits were
introduced.

Only a single trait method is present on the extension traits and it
works for single or multi channel listening setups.

Automatic reconnect behavior is implemented for PgPool based listeners.
All logic has been cut over to the `recv` impls for the PgListener
variants.

Use async-stream for a nice Stream interface.
2020-03-15 02:17:14 -07:00
Anthony Dodd
cb186e6a13 Updates from review and from testing. 2020-03-15 02:17:14 -07:00
Anthony Dodd
a52f36468b Implement Postgres LISTEN interface.
This changeset introduces an interface for using PostgreSQL's LISTEN
functionality from within sqlx.

The listen interface is implemented over the PgConnection, PgPool & the
PgPoolConnection types for ease of use. In the case of PgPool, a new
connection is acquired, and is then used for LISTEN functionality.

Closes #87
2020-03-15 02:17:14 -07:00
Ryan Leckey
ab20db14a2 Remove Sqlite prefix from SqliteStatement as it is an internal API 2020-03-15 02:16:31 -07:00
Ryan Leckey
68d4a0d258 sqlite: produce connection specific errors
postgres, mysql: use derive for Debug for error types
2020-03-15 02:14:23 -07:00
Ryan Leckey
f667910cbf sqlite: SqliteResultValue -> SqliteValue to match other drivers 2020-03-15 01:54:43 -07:00
Ryan Leckey
426361f361 sqlite: make SqliteConnection and Statement !Sync 2020-03-15 01:48:51 -07:00
Ryan Leckey
69b1d7feaa sqlite: add even more notes about Send/Sync 2020-03-15 00:34:13 -07:00
Ryan Leckey
97b50b95c0 sqlite: ensure that we additionally clear the bindings when resetting the statement 2020-03-14 23:48:00 -07:00
Ryan Leckey
2abc451655 sqlite: re-order Executor methods 2020-03-14 23:45:14 -07:00
Ryan Leckey
21097e1436 sqlite: clarlify Sync guarantee 2020-03-14 23:45:03 -07:00
Ryan Leckey
dd99fc351c suppress unused warnings 2020-03-14 19:54:19 -07:00
Ryan Leckey
cddaf1b34e remove unused import for spawn_blocking 2020-03-14 19:47:36 -07:00
Ryan Leckey
69ea41de1e sqlite: make the implementation far less naive
* WAL
 * sync = NORMAL, thought on this for awhile, all signs point to this being a very good default for WAL usage
 * separate worker thread per SQLite connection
2020-03-14 19:45:01 -07:00
Ryan Leckey
63ef32189d sqlite: implement support for multiple statements 2020-03-14 17:43:44 -07:00
Ryan Leckey
0130fe1479 sqlite: implement describe 2020-03-14 17:43:44 -07:00
Ryan Leckey
5f27026459 sqlite: implement remainder of query API 2020-03-14 17:43:44 -07:00
Ryan Leckey
a3799c3496 sqlite: implement command execution 2020-03-14 17:43:44 -07:00
Ryan Leckey
751efdf31b generalize MaybeOwnedConnection and clean up the connection file 2020-03-14 17:43:44 -07:00
Ryan Leckey
444ffff127 Run rustfmt 2020-03-14 17:43:44 -07:00
Ryan Leckey
30897dd6d9 Add additional notes to Executor 2020-03-14 17:43:44 -07:00
Ryan Leckey
0421c9fb42 Add explicit life times to Cursor 2020-03-14 17:43:44 -07:00
Ryan Leckey
1a48cf3b2c Reduce some duplication in type parsing 2020-03-14 17:43:44 -07:00
Ryan Leckey
7ab07016da sqlite: initial work in connection 2020-03-14 17:43:44 -07:00
Ryan Leckey
5d042e35b1 sqlite: stub 2020-03-14 17:43:44 -07:00
Ryan Leckey
553f03fa05 Add Database::RawBuffer to parameterize Encode 2020-03-14 17:43:44 -07:00
Ryan Leckey
cca096355f Run rustfmt 2020-03-14 17:43:44 -07:00
Ryan Leckey
27cd552a8c mysql: clean up protocol 2020-03-14 17:43:44 -07:00
Ryan Leckey
7a98253840 postgres: clean up protocol 2020-03-14 17:43:06 -07:00
Ryan Leckey
c7d416a1c3 Add Connection::begin 2020-03-14 17:43:06 -07:00
Ryan Leckey
cc88efe436 mysql: handle EOF packets if the server still requires them (MariaDB 10.1) 2020-03-14 17:29:59 -07:00
Ryan Leckey
12fa401556 log: trace the MySQL capability flags 2020-03-14 17:29:22 -07:00
Ryan Leckey
0a7415f542 Run rustfmt 2020-03-11 03:34:51 -07:00
Ryan Leckey
a165615f53 row: Row::get panics, Row::try_get is fallible, Query::map panics, Query::try_map is fallible 2020-03-11 03:32:52 -07:00
Ryan Leckey
9609a62ed1 Run rustfmt 2020-03-11 02:51:24 -07:00
Ryan Leckey
c14338d329 remove unused imports 2020-03-11 02:29:20 -07:00
Ryan Leckey
0eed8c5866 mysql: fix handling of multiple query statements for affected_rows 2020-03-11 02:18:45 -07:00
Ryan Leckey
69489caa4b mysql: initialize sql-mode and other options on establish 2020-03-11 02:18:27 -07:00
Ryan Leckey
e047f7c353 Remove custom Execute impl (no longer needed) 2020-03-11 01:55:18 -07:00
Ryan Leckey
e701aef9af Annotate the DB type for Decode in Decode for String 2020-03-11 01:55:06 -07:00
Ryan Leckey
038a6f2d30 Fix tests for MySQL chrono 2020-03-11 01:54:46 -07:00
Ryan Leckey
d6ce866c4b Fix TLS refactors for MySQL 2020-03-11 01:54:33 -07:00
Ryan Leckey
a9c3d9f44c Run rustfmt 2020-03-11 01:49:47 -07:00
Ryan Leckey
c9df8acc41 Add zero-allocation to MySQL query execution
WIP mysql compiles with types and executor commented out
2020-03-11 01:47:29 -07:00
Austin Bonander
de14a206ff remove pin-project workaround 2020-03-11 01:47:29 -07:00
Ryan Leckey
672f83c00e use pin-project and fix impl of GuardedFlush 2020-03-11 01:47:29 -07:00
Austin Bonander
f3fe264478 implement guarded flush for BufStream
closes #122
2020-03-11 01:47:29 -07:00
Austin Bonander
9cd3f5e75b rename Query::map() to try_map() and nail down some semantics 2020-03-11 01:47:29 -07:00
Austin Bonander
800af574c5 query_macros: allow Option<&str> to be passed in place of String
closes #93
2020-03-11 01:47:16 -07:00
Austin Bonander
4163388298 add nullability info to Describe
implement nullability check for Postgres as a query on pg_attribute

implement type name fetching for Postgres as part of `describe()`

add nullability for describe() to MySQL

improve errors with unknown result column type IDs in `query!()`

run cargo fmt and fix warnings

improve error when feature gates for chrono/uuid types is not turned on

workflows/rust: add step to UI-test missing optional features

improve error for unsupported/feature-gated input parameter types

fix `PgConnection::get_type_names()` for empty type IDs list

fix `tests::mysql::test_describe()` on MariaDB 10.4

copy-edit unsupported/feature-gated type errors in `query!()`

Postgres: fix SQL type of string array

closes #107
closes #17

Co-Authored-By: Anthony Dodd <Dodd.AnthonyJosiah@gmail.com>
2020-03-11 01:46:06 -07:00
Ryan Leckey
59cf900348 impl RefExecutor for &mut E ( where E is RefExecutor ) to allow &mut &Pool to continue working in 0.3 2020-03-11 01:46:06 -07:00
Ryan Leckey
13caade571 silence some unused warnings in postgres/tls with tls not compiled in 2020-03-11 01:46:06 -07:00
Ryan Leckey
6ffcf41b0f implement RefExecutor ( allow Query/QueryAs ) for Transaction 2020-03-11 01:46:06 -07:00
Ryan Leckey
10d2b45d9c update dependencies and clean up some more unused imports 2020-03-11 01:46:06 -07:00
Ryan Leckey
b8cd2e9388 remove unused imports 2020-03-11 01:45:04 -07:00
Ryan Leckey
10232a2cdc remove re-exports from sqlx-core and let sqlx fully define the module layout 2020-03-11 01:45:04 -07:00
Ryan Leckey
f337f1c602 postgres: implement text mode for chrono and clean up type tests 2020-03-11 01:44:41 -07:00
Ryan Leckey
7fbc26de05 tls: update tls module for postgres 2020-03-11 01:44:41 -07:00
Ryan Leckey
370ad81b8e remove now unused pieces of ConnectionSource and MaybeOwnedConnection 2020-03-11 01:44:41 -07:00
Ryan Leckey
47f3d77e59 query_as: fully implement query_as, required a db-specific ext trait 2020-03-11 01:44:41 -07:00