| 2 |
## $Id$ |
## $Id$ |
| 3 |
## -------------------------------------------------------------------------------- |
## -------------------------------------------------------------------------------- |
| 4 |
## $Log$ |
## $Log$ |
| 5 |
|
## Revision 1.3 2002/07/27 00:28:20 cvsjoko |
| 6 |
|
## bugfixes |
| 7 |
|
## |
| 8 |
|
## Revision 1.2 2002/07/20 11:09:58 cvsjoko |
| 9 |
|
## + bugfixes |
| 10 |
|
## + dont' print sql-errors |
| 11 |
|
## |
| 12 |
## Revision 1.1 2002/07/19 18:14:03 cvsjoko |
## Revision 1.1 2002/07/19 18:14:03 cvsjoko |
| 13 |
## no message |
## no message |
| 14 |
## |
## |
| 112 |
croak "please supply a dsn or a \"dbmeta\"-hash" if (!$dbmeta); |
croak "please supply a dsn or a \"dbmeta\"-hash" if (!$dbmeta); |
| 113 |
$dbmeta = patch_dbmeta($dbmeta); |
$dbmeta = patch_dbmeta($dbmeta); |
| 114 |
if (!$dbmeta->{connected}) { |
if (!$dbmeta->{connected}) { |
| 115 |
if ($dbmeta->{dbh} = DBI->connect($dbmeta->{dsn})) { |
if ($dbmeta->{dbh} = DBI->connect($dbmeta->{dsn}, '', '', { PrintError => 0 } )) { |
| 116 |
$dbmeta->{dbh}->trace($dbmeta->{trace_level}, $dbmeta->{trace_file}); |
$dbmeta->{dbh}->trace($dbmeta->{trace_level}, $dbmeta->{trace_file}); |
| 117 |
$dbmeta->{dbh}->{PrintError} = 0; |
$dbmeta->{dbh}->{PrintError} = 0; |
| 118 |
$dbmeta->{connected} = 1; |
$dbmeta->{connected} = 1; |
| 119 |
$dbmeta_ref_cache = $dbmeta; |
$dbmeta_ref_cache = $dbmeta; |
| 120 |
|
return 1; |
| 121 |
} |
} |
| 122 |
} |
} |
| 123 |
} |
} |
| 173 |
trace_level => 1, |
trace_level => 1, |
| 174 |
trace_file => 'dbitrace', |
trace_file => 'dbitrace', |
| 175 |
}; |
}; |
| 176 |
connectTarget($dbmeta); |
my $bool_ok; |
| 177 |
sendSql($sql); |
if (connectTarget($dbmeta)) { |
| 178 |
disconnectTarget($dbmeta); |
sendSql($sql); |
| 179 |
|
#print "state: ", $dbmeta->{dbh}->state, "\n"; |
| 180 |
|
#print "err ", $dbmeta->{dbh}->err, "\n"; |
| 181 |
|
#$bool_ok = ($dbmeta->{dbh} && $dbmeta->{dbh}->state && !$dbmeta->{dbh}->err); |
| 182 |
|
$bool_ok = ($dbmeta->{dbh} && !$dbmeta->{dbh}->err); |
| 183 |
|
disconnectTarget($dbmeta); |
| 184 |
|
} |
| 185 |
|
return $bool_ok; |
| 186 |
} |
} |
| 187 |
|
|
| 188 |
sub createSqlDb { |
sub createSqlDb { |
| 189 |
my $dsn = shift; |
my $dsn = shift; |
| 190 |
my $dbname = getDbNameByDsn($dsn); |
my $dbname = getDbNameByDsn($dsn); |
| 191 |
print " - creating database $dbname", "\n"; |
print " - creating rdbms-database $dbname ($dsn) ..."; |
| 192 |
my $sql; |
my $sql; |
| 193 |
$sql = "CREATE DATABASE $dbname;"; |
$sql = "CREATE DATABASE $dbname;"; |
| 194 |
sqlDbAction($dsn, $sql); |
if ( sqlDbAction($dsn, $sql) ) { |
| 195 |
|
print "ok", "\n"; |
| 196 |
|
return 1; |
| 197 |
|
} else { |
| 198 |
|
print "failed", "\n"; |
| 199 |
|
return 0; |
| 200 |
|
} |
| 201 |
} |
} |
| 202 |
|
|
| 203 |
sub dropSqlDb { |
sub dropSqlDb { |
| 204 |
my $dsn = shift; |
my $dsn = shift; |
| 205 |
my $dbname = getDbNameByDsn($dsn); |
my $dbname = getDbNameByDsn($dsn); |
| 225 |
return 1 if ($bool_tablesHere); |
return 1 if ($bool_tablesHere); |
| 226 |
} |
} |
| 227 |
|
|
|
1; |
|
| 228 |
|
1; |