Add cursor name support in Statement

Author: asfernandes

src/fb-cpp/Statement.cpp

@@ -53,6 +53,9 @@ Statement::Statement(
 	statementHandle.reset(attachment.getHandle()->prepare(&statusWrapper, transaction.getHandle().get(),
 		static_cast<unsigned>(sql.length()), sql.data(), SQL_DIALECT_CURRENT, flags));
 
+	if (options.getCursorName().has_value())
+		statementHandle->setCursorName(&statusWrapper, options.getCursorName()->c_str());
+
 	type = static_cast<StatementType>(statementHandle->getType(&statusWrapper));
 
 	switch (type)

src/fb-cpp/Statement.h

@@ -110,9 +110,29 @@ namespace fbcpp
 			return *this;
 		}
 
+		///
+		/// @brief Returns the cursor name to be set for the statement.
+		///
+		const std::optional<std::string>& getCursorName() const
+		{
+			return cursorName;
+		}
+
+		///
+		/// @brief Sets the cursor name for the statement.
+		/// @param value The name of the cursor.
+		/// @return Reference to this instance for fluent configuration.
+		///
+		StatementOptions& setCursorName(const std::string& value)
+		{
+			cursorName = value;
+			return *this;
+		}
+
 	private:
 		bool prefetchLegacyPlan = false;
 		bool prefetchPlan = false;
+		std::optional<std::string> cursorName;
 	};
 
 	///

src/test/Statement.cpp

@@ -1459,6 +1459,51 @@ BOOST_AUTO_TEST_CASE(cursorMethodsReturnFalseWithoutResultSet)
 	BOOST_CHECK_EQUAL(insert.fetchRelative(1), false);
 }
 
+BOOST_AUTO_TEST_CASE(cursorName)
+{
+	const auto database = getTempFile("Statement-cursorName.fdb");
+
+	Attachment attachment{CLIENT, database, AttachmentOptions().setCreateDatabase(true)};
+	FbDropDatabase attachmentDrop{attachment};
+
+	Transaction transaction{attachment};
+
+	Statement ddl{attachment, transaction, "create table t (col integer)"};
+	ddl.execute(transaction);
+	transaction.commitRetaining();
+
+	Statement insert{attachment, transaction, "insert into t (col) values (?)"};
+	for (int i = 1; i <= 3; ++i)
+	{
+		insert.setInt32(0, i);
+		insert.execute(transaction);
+	}
+
+	Statement select{
+		attachment, transaction, "select col from t order by col for update", StatementOptions().setCursorName("c")};
+	BOOST_REQUIRE(select.execute(transaction));
+
+	BOOST_CHECK_EQUAL(select.getInt32(0).value(), 1);
+
+	Statement updateStmt{attachment, transaction, "update t set col = col + 10 where current of c returning col"};
+	BOOST_REQUIRE(updateStmt.execute(transaction));
+	BOOST_CHECK_EQUAL(updateStmt.getInt32(0).value(), 11);
+
+	BOOST_CHECK(select.fetchNext());
+	BOOST_CHECK_EQUAL(select.getInt32(0).value(), 2);
+
+	Statement deleteStmt{attachment, transaction, "delete from t where current of c returning col"};
+	BOOST_REQUIRE(deleteStmt.execute(transaction));
+	BOOST_CHECK_EQUAL(deleteStmt.getInt32(0).value(), 2);
+
+	Statement verify{attachment, transaction, "select col from t order by col"};
+	BOOST_REQUIRE(verify.execute(transaction));
+	BOOST_CHECK_EQUAL(verify.getInt32(0).value(), 3);
+	BOOST_CHECK(verify.fetchNext());
+	BOOST_CHECK_EQUAL(verify.getInt32(0).value(), 11);
+	BOOST_CHECK(!verify.fetchNext());
+}
+
 BOOST_AUTO_TEST_SUITE_END()