clear old query return value

dboissin · dboissin · commit 7349866475e7 · 2014-10-05T15:28:52.000+02:00
diff --git a/postgresql-async/src/main/scala/com/github/mauricio/async/db/postgresql/PostgreSQLConnection.scala b/postgresql-async/src/main/scala/com/github/mauricio/async/db/postgresql/PostgreSQLConnection.scala
@@ -303,6 +303,7 @@ class PostgreSQLConnection
 
   private def succeedQueryPromise(result: QueryResult) {
     this.queryResult = None
+    this.currentQuery = None
     this.clearQueryPromise.foreach {
       _.success(result)
     }
diff --git a/postgresql-async/src/test/scala/com/github/mauricio/async/db/postgresql/PostgreSQLConnectionSpec.scala b/postgresql-async/src/test/scala/com/github/mauricio/async/db/postgresql/PostgreSQLConnectionSpec.scala
@@ -428,6 +428,20 @@ class PostgreSQLConnectionSpec extends Specification with DatabaseTestHelper {
 
     }
 
+    "insert without return after select" in {
+
+      withHandler {
+        handler =>
+          executeDdl(handler, this.preparedStatementCreate)
+          executeDdl(handler, this.preparedStatementInsert, 1)
+          executeDdl(handler, this.preparedStatementSelect, 1)
+          val result = executeQuery(handler, this.preparedStatementInsert2)
+
+          result.rows === None
+      }
+
+    }
+
   }
 
 }

Original file line number	Diff line number	Diff line change
`@@ -303,6 +303,7 @@ class PostgreSQLConnection`
`303`	`303`
`304`	`304`	`private def succeedQueryPromise(result: QueryResult) {`
`305`	`305`	`this.queryResult = None`
	`306`	`+ this.currentQuery = None`
`306`	`307`	`this.clearQueryPromise.foreach {`
`307`	`308`	`_.success(result)`
`308`	`309`	`}`
Original file line number	Diff line number	Diff line change
`@@ -428,6 +428,20 @@ class PostgreSQLConnectionSpec extends Specification with DatabaseTestHelper {`
`428`	`428`
`429`	`429`	`}`
`430`	`430`
	`431`	`+ "insert without return after select" in {`
	`432`	`+`
	`433`	`+ withHandler {`
	`434`	`+ handler =>`
	`435`	`+ executeDdl(handler, this.preparedStatementCreate)`
	`436`	`+ executeDdl(handler, this.preparedStatementInsert, 1)`
	`437`	`+ executeDdl(handler, this.preparedStatementSelect, 1)`
	`438`	`+ val result = executeQuery(handler, this.preparedStatementInsert2)`
	`439`	`+`
	`440`	`+ result.rows === None`
	`441`	`+ }`
	`442`	`+`
	`443`	`+ }`
	`444`	`+`
`431`	`445`	`}`
`432`	`446`
`433`	`447`	`}`