Author: spadkins
Date: Wed Apr 9 05:53:20 2008
New Revision: 11061
Modified:
p5ee/trunk/App-Repository/CHANGES
p5ee/trunk/App-Repository/lib/App/Repository/DBI.pm
Log:
consult the "table" config value for table to see the physical table (good
for schema-qualified table names)
Modified: p5ee/trunk/App-Repository/CHANGES
==============================================================================
--- p5ee/trunk/App-Repository/CHANGES (original)
+++ p5ee/trunk/App-Repository/CHANGES Wed Apr 9 05:53:20 2008
@[EMAIL PROTECTED]
-2,6 +2,9 @[EMAIL PROTECTED]
# CHANGE LOG
#########################################
+0.967
+ x App::Repository::_mk_*(): consult the "table" config value for table
to see the physical table (good for schema-qualified table names)
+
0.966
x App::Repository::mk_select_joined_sql(): enable param substitutions in
dbexpr's
x App::Repository::get_rows()/get_row(): use query caching if turned on
for the table ({cache_name} => "name_of_shared_datastore")
Modified: p5ee/trunk/App-Repository/lib/App/Repository/DBI.pm
==============================================================================
--- p5ee/trunk/App-Repository/lib/App/Repository/DBI.pm (original)
+++ p5ee/trunk/App-Repository/lib/App/Repository/DBI.pm Wed Apr 9
05:53:20 2008
@[EMAIL PROTECTED]
-901,7 +901,9 @[EMAIL PROTECTED]
$direction = $options->{direction} || $options->{directions}; #
{directions} is deprecated
my $modifier = $options->{distinct} ? " distinct" : "";
- $sql = "select$modifier\n " . join(",\n ", @[EMAIL PROTECTED]
) . "\nfrom
$table\n";
+ my $table_def = $self->get_table_def($table);
+ my $realtable = $table_def->{table} || $table;
+ $sql = "select$modifier\n " . join(",\n ", @[EMAIL PROTECTED]
) . "\nfrom
$realtable\n";
$sql .= $self->_mk_where_clause($table, $params);
if (defined $order_by && $#$order_by > -1) {
@[EMAIL PROTECTED]
-1720,9 +1722,11 @[EMAIL PROTECTED]
$self->{error} = "Database->_mk_insert_row_sql(): no columns
specified";
return();
}
- my $tabcols = $self->{table}{$table}{column};
+ my $table_def = $self->get_table_def($table);
+ my $tabcols = $table_def->{column};
- $sql = "insert into $table\n";
+ my $realtable = $table_def->{table} || $table;
+ $sql = "insert into $realtable\n";
$values = "values\n";
for ($colnum = 0; $colnum <= $#$cols; $colnum++) {
$col = $cols->[$colnum];
@[EMAIL PROTECTED]
-1800,7 +1804,9 @[EMAIL PROTECTED]
}
}
}
- my $sql = "insert into $table\n (" . join(",\n ",@[EMAIL PROTECTED]
) .
")\nvalues\n (" . join(@[EMAIL PROTECTED]
) . ")\n";
+ my $table_def = $self->get_table_def($table);
+ my $realtable = $table_def->{table} || $table;
+ my $sql = "insert into $realtable\n (" . join(",\n ",@[EMAIL PROTECTED]
) .
")\nvalues\n (" . join(@[EMAIL PROTECTED]
) . ")\n";
&App::sub_exit($sql) if ($App::trace);
$sql;
}
@[EMAIL PROTECTED]
-1936,7 +1942,9 @[EMAIL PROTECTED]
}
}
- my $sql = "update $table set\n " . join(",\n ",@[EMAIL PROTECTED]
) . "\n" .
$where;
+ my $table_def = $self->get_table_def($table);
+ my $realtable = $table_def->{table} || $table;
+ my $sql = "update $realtable set\n " . join(",\n ",@[EMAIL PROTECTED]
) . "\n" .
$where;
&App::sub_exit($sql) if ($App::trace);
$sql;
}
@[EMAIL PROTECTED]
-2038,7 +2046,9 @[EMAIL PROTECTED]
die "_mk_delete_sql() unrecognized params type";
}
- my $sql = "delete from $table\n$where";
+ my $table_def = $self->get_table_def($table);
+ my $realtable = $table_def->{table} || $table;
+ my $sql = "delete from $realtable\n$where";
&App::sub_exit($sql) if ($App::trace);
$sql;
}
@[EMAIL PROTECTED]
-2060,7 +2070,9 @[EMAIL PROTECTED]
$colused[$#$cols] = 0; # pre-extend the array
- $sql = "delete from $table\n";
+ my $table_def = $self->get_table_def($table);
+ my $realtable = $table_def->{table} || $table;
+ $sql = "delete from $realtable\n";
if (defined $keycolidx && $#$keycolidx > -1) {
for ($i = 0; $i <= $#$keycolidx; $i++) {
@[EMAIL PROTECTED]
-2099,7 +2111,9 @[EMAIL PROTECTED]
$self->_load_table_metadata($table) if (!defined
$self->{table}{$table}{loaded});
my ($sql);
- $sql = "delete from $table\n";
+ my $table_def = $self->get_table_def($table);
+ my $realtable = $table_def->{table} || $table;
+ $sql = "delete from $realtable\n";
$sql .= $self->_mk_where_clause($table, $params);
&App::sub_exit($sql) if ($App::trace);
$sql;
|
