Commite4be50d

committed

feat: add is_really_closed feature to non-async postgres lib

1 parent720897d commite4be50dCopy full SHA for e4be50d

File tree

+26

-0

lines changed

+26

-0

lines changed

Lines changed: 5 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -487,6 +487,11 @@ impl Client {`
`487`	`487`	`self.connection.block_on(self.client.batch_execute(query))`
`488`	`488`	`}`
`489`	`489`
	`490`	`+/// Check the connection is alive and wait for the confirmation.`
	`491`	`+pubfncheck_connection(&mutself) ->Result<(),Error>{`
	`492`	`+self.connection.block_on(self.client.check_connection())`
	`493`	`+}`
	`494`	`+`
`490`	`495`	`/// Begins a new database transaction.`
`491`	`496`	`///`
`492`	`497`	/// The transaction will roll back by default - use the `commit` method to commit it.

Lines changed: 21 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -508,3 +508,24 @@ fn check_send() {`
`508`	`508`	`is_send::<Statement>();`
`509`	`509`	`is_send::<Transaction<'_>>();`
`510`	`510`	`}`
	`511`	`+`
	`512`	`+#[test]`
	`513`	`+fnis_closed(){`
	`514`	`+letmut client =Client::connect("host=localhost port=5433 user=postgres",NoTls).unwrap();`
	`515`	`+assert!(!client.is_closed());`
	`516`	`+ client.check_connection().unwrap();`
	`517`	`+`
	`518`	`+let row = client.query_one("select pg_backend_pid()",&[]).unwrap();`
	`519`	`+let pid:i32 = row.get(0);`
	`520`	`+`
	`521`	`+{`
	`522`	`+letmut client2 =Client::connect("host=localhost port=5433 user=postgres",NoTls).unwrap();`
	`523`	`+ client2`
	`524`	`+.query("SELECT pg_terminate_backend($1)",&[&pid])`
	`525`	`+.unwrap();`
	`526`	`+}`
	`527`	`+`
	`528`	`+assert!(!client.is_closed());`
	`529`	`+ client.check_connection().unwrap_err();`
	`530`	`+assert!(client.is_closed());`
	`531`	`+}`

Comments

(0)