|
[-]
[+]
|
Changed |
perl-DBD-cego.changes
|
|
|
|
[-]
[+]
|
Changed |
perl-DBD-cego.spec
^
|
|
|
|
[-]
[+]
|
Changed |
DBD-cego-1.2.0.tar.bz2/README
^
|
| @@ -4,7 +4,7 @@
--------
A Perl DBD driver for the Cego database system
- Version 1.1.15
+ Version 1.2.0
(C)opyright 2007,2008,2009,2010,2011,2012 Bjoern Lemke
@@ -14,9 +14,9 @@
-----------
To build the Cego DBD driver, you need the following library packages available from www.lemke-it.com:
- lfc-1.2.0.tar.gz
+ lfc-1.3.0.tar.gz
lfcxml-1.0.26.tar.gz
- cego-2.12.4.tar.gz ( client library )
+ cego-2.13.0.tar.gz ( client library )
Tested platforms and compliers
----------------------------
|
|
[-]
[+]
|
Changed |
DBD-cego-1.2.0.tar.bz2/dbd.def
^
|
| @@ -1 +1 @@
-localhost:2200:sysmt:sysmt:sysmt
+localhost:2200:TS1:lemke:lemke
|
|
[-]
[+]
|
Changed |
DBD-cego-1.2.0.tar.bz2/dbdimp.c
^
|
| @@ -90,8 +90,20 @@
Chain logFile(imp_dbh->logfile);
Chain logMode(imp_dbh->logmode);
+ Chain prot(imp_dbh->protocol);
- imp_dbh->cgnet = new CegoNet( logFile, logMode );
+ CegoDbHandler::ProtocolType protocol;
+ if ( prot == Chain("serial"))
+ protocol=CegoDbHandler::SERIAL;
+ else if ( prot == Chain("xml"))
+ protocol=CegoDbHandler::XML;
+ else
+ {
+ cego_error(dbh, 1, "Invalid protocol" );
+ return FALSE;
+ }
+
+ imp_dbh->cgnet = new CegoNet( protocol, logFile, logMode );
try
{
@@ -382,8 +394,7 @@
{
stmt = *pChunk;
}
-
-
+
pChunk = imp_sth->stmtChunks->Next();
while ( pChunk )
{
@@ -471,6 +482,7 @@
}
else if ( pParam->getId() == 1 )
{
+
sv_setpv(pSV, (char*)retValue.valAsChain());
}
}
@@ -571,7 +583,7 @@
Chain msg;
CegoDbHandler::ResultType res;
- ListT<CegoField> fvl;
+ ListT<CegoFieldValue> fvl;
try
{
@@ -579,20 +591,20 @@
{
av = DBIS->get_fbav(imp_sth);
int pos=0;
- CegoField *pF = fvl.First();
- while ( pF )
+ CegoFieldValue *pFV = fvl.First();
+ while ( pFV )
{
- if ( pF->getValue().isNull() )
+ if ( pFV->isNull() )
{
sv_setpvn(AvARRAY(av)[pos], 0, 0);
}
else
{
sv_setpvn(AvARRAY(av)[pos],
- pF->getValue().valAsChain(),
- pF->getValue().valAsChain().length() - 1 );
+ pFV->valAsChain(),
+ pFV->valAsChain().length() - 1 );
}
- pF = fvl.Next();
+ pFV = fvl.Next();
pos++;
}
fvl.Empty();
@@ -706,6 +718,11 @@
strcpy(imp_dbh->logmode, val);
return TRUE;
}
+ if (strncmp(key, "protocol", 8) == 0)
+ {
+ strcpy(imp_dbh->protocol, val);
+ return TRUE;
+ }
if (strncmp(key, "port", 4) == 0)
{
imp_dbh->port = atoi(val);
|
|
[-]
[+]
|
Changed |
DBD-cego-1.2.0.tar.bz2/dbdimp.h
^
|
| @@ -39,6 +39,7 @@
#define MAXLOGFILE 100
#define MAXLOGMODE 10
+#define MAXPROTSTRING 10
class CegoDBDParam {
@@ -132,6 +133,7 @@
int port;
char logfile[MAXLOGFILE];
char logmode[MAXLOGMODE];
+ char protocol[MAXPROTSTRING];
bool activeTransaction;
bool activeQuery;
|
|
[-]
[+]
|
Changed |
DBD-cego-1.2.0.tar.bz2/t/01connect.t
^
|
| @@ -8,7 +8,7 @@
my ($host, $port,$tableset,$user,$pwd) = split(/:/,$line );
close(DEF);
-my $dbh = DBI->connect("dbi:Cego:tableset=$tableset;hostname=$host;port=$port;logfile=cegoDBD.log;logmode=debug", "$user", "$pwd");
+my $dbh = DBI->connect("dbi:Cego:tableset=$tableset;hostname=$host;port=$port;protocol=serial;logfile=cegoDBD.log;logmode=debug", "$user", "$pwd");
ok($dbh);
$dbh->{AutoCommit} = 1;
|
|
[-]
[+]
|
Changed |
DBD-cego-1.2.0.tar.bz2/t/02create_table.t
^
|
| @@ -8,7 +8,7 @@
my ($host, $port,$tableset,$user,$pwd) = split(/:/, $line );
close(DEF);
-my $dbh = DBI->connect("dbi:Cego:tableset=$tableset;hostname=$host;port=$port;logfile=cegoDBD.log;logmode=debug", "$user", "$pwd");
+my $dbh = DBI->connect("dbi:Cego:tableset=$tableset;hostname=$host;port=$port;protocol=serial;logfile=cegoDBD.log;logmode=debug", "$user", "$pwd");
ok($dbh);
$dbh->do("drop if exists table tab1;");
|
|
[-]
[+]
|
Changed |
DBD-cego-1.2.0.tar.bz2/t/03insert.t
^
|
| @@ -8,7 +8,7 @@
my ($host, $port,$tableset,$user,$pwd) = split(/:/, $line );
close(DEF);
-my $dbh = DBI->connect("dbi:Cego:tableset=$tableset;hostname=$host;port=$port;logfile=cegoDBD.log;logmode=debug", "$user", "$pwd");
+my $dbh = DBI->connect("dbi:Cego:tableset=$tableset;hostname=$host;port=$port;protocol=serial;logfile=cegoDBD.log;logmode=debug", "$user", "$pwd");
ok($dbh);
$dbh->{AutoCommit} = 1;
|
|
[-]
[+]
|
Changed |
DBD-cego-1.2.0.tar.bz2/t/04bind_insert.t
^
|
| @@ -10,7 +10,7 @@
my ($host, $port,$tableset,$user,$pwd) = split(/:/, $line );
close(DEF);
-my $dbh = DBI->connect("dbi:Cego:tableset=$tableset;hostname=$host;port=$port;logfile=cegoDBD.log;logmode=debug", "$user", "$pwd");
+my $dbh = DBI->connect("dbi:Cego:tableset=$tableset;hostname=$host;port=$port;protocol=serial;logfile=cegoDBD.log;logmode=debug", "$user", "$pwd");
ok($dbh);
my $sth = $dbh->prepare("insert into tab1 values ( ? , ? );");
|
|
[-]
[+]
|
Changed |
DBD-cego-1.2.0.tar.bz2/t/05simple_select.t
^
|
| @@ -8,7 +8,7 @@
my ($host, $port,$tableset,$user,$pwd) = split(/:/, $line );
close(DEF);
-my $dbh = DBI->connect("dbi:Cego:tableset=$tableset;hostname=$host;port=$port;logfile=cegoDBD.log;logmode=debug", "$user", "$pwd");
+my $dbh = DBI->connect("dbi:Cego:tableset=$tableset;hostname=$host;port=$port;protocol=serial;logfile=cegoDBD.log;logmode=debug", "$user", "$pwd");
ok($dbh);
my $sth = $dbh->prepare("select * from tab1;");
|
|
[-]
[+]
|
Changed |
DBD-cego-1.2.0.tar.bz2/t/06transaction.t
^
|
| @@ -10,7 +10,7 @@
my ($host, $port,$tableset,$user,$pwd) = split(/:/, $line );
close(DEF);
-my $dbh = DBI->connect("dbi:Cego:tableset=$tableset;hostname=$host;port=$port;logfile=cegoDBD.log;logmode=debug", "$user", "$pwd", { AutoCommit => 0} );
+my $dbh = DBI->connect("dbi:Cego:tableset=$tableset;hostname=$host;port=$port;protocol=serial;logfile=cegoDBD.log;logmode=debug", "$user", "$pwd", { AutoCommit => 0} );
ok($dbh);
my $sth = $dbh->prepare("insert into tab1 values ( ? , ? );");
|
|
[-]
[+]
|
Changed |
DBD-cego-1.2.0.tar.bz2/t/07create_proc.t
^
|
| @@ -8,7 +8,7 @@
my ($host, $port,$tableset,$user,$pwd) = split(/:/, $line );
close(DEF);
-my $dbh = DBI->connect("dbi:Cego:tableset=$tableset;hostname=$host;port=$port;logfile=cegoDBD.log;logmode=debug", "$user", "$pwd");
+my $dbh = DBI->connect("dbi:Cego:tableset=$tableset;hostname=$host;port=$port;protocol=serial;logfile=cegoDBD.log;logmode=debug", "$user", "$pwd");
ok($dbh);
my $sth;
|
|
[-]
[+]
|
Changed |
DBD-cego-1.2.0.tar.bz2/t/08exec_proc.t
^
|
| @@ -8,7 +8,7 @@
my ($host, $port,$tableset,$user,$pwd) = split(/:/, $line );
close(DEF);
-my $dbh = DBI->connect("dbi:Cego:tableset=$tableset;hostname=$host;port=$port;logfile=cegoDBD.log;logmode=debug", "$user", "$pwd");
+my $dbh = DBI->connect("dbi:Cego:tableset=$tableset;hostname=$host;port=$port;protocol=serial;logfile=cegoDBD.log;logmode=debug", "$user", "$pwd");
ok($dbh);
my $sth;
|
|
[-]
[+]
|
Changed |
DBD-cego-1.2.0.tar.bz2/t/09bindinout.t
^
|
| @@ -9,7 +9,7 @@
my ($host, $port,$tableset,$user,$pwd) = split(/:/,$line );
close(DEF);
-my $dbh = DBI->connect("dbi:Cego:tableset=$tableset;hostname=$host;port=$port;logfile=cegoDBD.log;logmode=debug", "$user", "$pwd");
+my $dbh = DBI->connect("dbi:Cego:tableset=$tableset;hostname=$host;port=$port;protocol=serial;logfile=cegoDBD.log;logmode=debug", "$user", "$pwd");
ok($dbh);
$dbh->do("drop if exists procedure myInOut;");
@@ -45,14 +45,13 @@
print "outVar=" . $outVar ."\n";
print "xVar=" . $xVar ."\n";
-
if ( $outVar eq "TestString" )
{
ok( 1 );
}
else
{
- ok( 0 );
+ ok( 0 );
}
$sth->finish;
ok($sth);
|
