generic-library/poco
1
0
Fork 0
mirror of https://github.com/pocoproject/poco.git synced 2025-01-18 08:22:37 +01:00
Code Issues Projects Releases Wiki Activity

Oracle stored proc recordset retrieval

Browse Source
This commit is contained in:
Aleksandar Fabijanic 2007-10-30 19:46:55 +00:00
parent bd2a18d7a8
commit 76221cc707
4 changed files with 45 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
Data/ODBC/testsuite/src/ODBCOracleTest.cpp
View File

@ -918,6 +918,43 @@ void ODBCOracleTest::testStoredProcedure()
assert(-1 == i);
dropObject("PROCEDURE", "storedProcedure");
recreatePersonTable();
typedef Tuple<std::string, std::string, std::string, int> Person;
std::vector<Person> people;
people.push_back(Person("Simpson", "Homer", "Springfield", 42));
people.push_back(Person("Simpson", "Bart", "Springfield", 12));
people.push_back(Person("Simpson", "Lisa", "Springfield", 10));
*_pSession << "INSERT INTO Person VALUES (?, ?, ?, ?)", use(people), now;
*_pSession << "CREATE OR REPLACE "
"PROCEDURE storedCursorProcedure(ret OUT SYS_REFCURSOR, ageLimit IN NUMBER) IS "
" BEGIN "
" OPEN ret FOR "
" SELECT * "
" FROM Person "
" WHERE Age < ageLimit "
" ORDER BY Age DESC; "
" END storedCursorProcedure;" , now;
people.clear();
int age = 13;
*_pSession << "{call storedCursorProcedure(?)}", in(age), into(people), now;
assert (2 == people.size());
assert (Person("Simpson", "Bart", "Springfield", 12) == people[0]);
assert (Person("Simpson", "Lisa", "Springfield", 10) == people[1]);
Statement stmt = ((*_pSession << "{call storedCursorProcedure(?)}", in(age), now));
RecordSet rs(stmt);
assert (rs["LastName"] == "Simpson");
assert (rs["FirstName"] == "Bart");
assert (rs["Address"] == "Springfield");
assert (rs["Age"] == 12);
dropObject("TABLE", "Person");
dropObject("PROCEDURE", "storedCursorProcedure");
*_pSession << "CREATE OR REPLACE "
"PROCEDURE storedProcedure(inParam IN NUMBER, outParam OUT NUMBER) IS "
" BEGIN outParam := inParam*inParam; "
@ -1131,7 +1168,7 @@ void ODBCOracleTest::testAsync()
recreateIntsTable();
_pSession->setFeature("autoBind", bindValues[i]);
_pSession->setFeature("autoExtract", bindValues[i+1]);
_pExecutor->asynchronous();
_pExecutor->asynchronous(2000);
i += 2;
}
@ -1279,7 +1316,10 @@ bool ODBCOracleTest::canConnect(const std::string& driver, const std::string& ds
{
std::cout << "DSN found: " << itDSN->first
<< " (" << itDSN->second << ')' << std::endl;
format(_dbConnString, "DSN=%s", dsn);
format(_dbConnString,
"DSN=%s;"
"UID=Scott;"
"PWD=Tiger;", dsn);
return true;
}
}

2
Data/ODBC/testsuite/src/ODBCPostgreSQLTest.cpp
View File

@ -1003,7 +1003,7 @@ void ODBCPostgreSQLTest::testAsync()
recreateIntsTable();
_pSession->setFeature("autoBind", bindValues[i]);
_pSession->setFeature("autoExtract", bindValues[i+1]);
_pExecutor->asynchronous();
_pExecutor->asynchronous(2000);
i += 2;
}
}

3
Data/ODBC/testsuite/src/SQLExecutor.cpp
View File

@ -2241,11 +2241,10 @@ void SQLExecutor::stdVectorBool()
}
void SQLExecutor::asynchronous()
void SQLExecutor::asynchronous(int rowCount)
{
Session tmp = *_pSession;
int rowCount = 2000;
std::vector<int> data(rowCount);
Statement stmt = (tmp << "INSERT INTO Strings VALUES(?)", use(data));
Statement::Result result = stmt.executeAsync();

2
Data/ODBC/testsuite/src/SQLExecutor.h
View File

@ -134,7 +134,7 @@ public:
void rowIterator();
void stdVectorBool();
void asynchronous();
void asynchronous(int rowCount = 500);
private:
Poco::Data::Session* _pSession;