--- loncom/interface/lonmysql.pm 2002/08/21 21:29:51 1.7
+++ loncom/interface/lonmysql.pm 2004/03/03 17:19:06 1.19
@@ -1,7 +1,7 @@
# The LearningOnline Network with CAPA
# MySQL utility functions
#
-# $Id: lonmysql.pm,v 1.7 2002/08/21 21:29:51 matthew Exp $
+# $Id: lonmysql.pm,v 1.19 2004/03/03 17:19:06 matthew Exp $
#
# Copyright Michigan State University Board of Trustees
#
@@ -32,6 +32,8 @@ package Apache::lonmysql;
use strict;
use DBI;
use Apache::lonnet();
+use POSIX qw(strftime mktime);
+
######################################################################
######################################################################
@@ -71,17 +73,18 @@ To create a table, you need a descriptio
for &create_table for a description of what is needed.
$table_id = &create_table({
- columns => {
- id => {
- type => 'INT',
- restrictions => 'NOT NULL',
- primary_key => 'yes',
- auto_inc => 'yes'
- }
- verbage => { type => 'TEXT' },
- },
- column_order => [qw/id verbage idx_verbage/],
- fulltext => [qw/verbage/],
+ id => 'tableid', # usually you will use the returned id
+ columns => (
+ { name => 'id',
+ type => 'INT',
+ restrictions => 'NOT NULL',
+ primary_key => 'yes',
+ auto_inc => 'yes'
+ },
+ { name => 'verbage',
+ type => 'TEXT' },
+ ),
+ fulltext => [qw/verbage/],
});
The above command will create a table with two columns, 'id' and 'verbage'.
@@ -230,6 +233,10 @@ an array reference which holds the order
The statement handler for row inserts.
+=item row_replace_sth
+
+The statement handler for row inserts.
+
=back
Col_order and row_insert_sth are kept internally by lonmysql and are not
@@ -343,6 +350,33 @@ sub connect_to_db {
=pod
+=item &verify_sql_connection()
+
+Inputs: none.
+
+Returns: 0 (failure) or 1 (success)
+
+Checks to make sure the database can be connected to. It does not
+initialize anything in the lonmysql package.
+
+=cut
+
+###############################
+sub verify_sql_connection {
+ my $connection;
+ if (! ($connection = DBI->connect("DBI:mysql:loncapa","www",
+ $Apache::lonnet::perlvar{'lonSqlAccess'},
+ { RaiseError=>0,PrintError=>0}))) {
+ return 0;
+ }
+ undef($connection);
+ return 1;
+}
+
+###############################
+
+=pod
+
=item &disconnect_from_db()
Inputs: none.
@@ -362,6 +396,9 @@ sub disconnect_from_db {
if (exists($Tables{$_}->{'row_insert_sth'})) {
delete($Tables{$_}->{'row_insert_sth'});
}
+ if (exists($Tables{$_}->{'row_replace_sth'})) {
+ delete($Tables{$_}->{'row_replace_sth'});
+ }
}
$dbh->disconnect if ($dbh);
$debugstring = "Disconnected from database.";
@@ -388,6 +425,26 @@ sub number_of_rows {
return undef if (! defined(&update_table_info($table_id)));
return $Tables{&translate_id($table_id)}->{'Rows'};
}
+###############################
+
+=pod
+
+=item &get_dbh()
+
+Input: nothing
+
+Returns: the database handler, or undef on error.
+
+This routine allows the programmer to gain access to the database handler.
+Be careful.
+
+=cut
+
+###############################
+sub get_dbh {
+ return undef if (! defined(&connect_to_db()));
+ return $dbh;
+}
###############################
@@ -427,7 +484,7 @@ sub get_debug {
=pod
-=item &update_table_info($table_id)
+=item &update_table_info()
Inputs: table id
@@ -502,12 +559,32 @@ sub update_table_info {
$debugstring = "Retrieved table info for $tablename";
return 1;
}
+###############################
+
+=pod
+
+=item &col_order()
+
+Inputs: table id
+
+Returns: array with column order
+
+=cut
+
+sub col_order {
+ my $table_id=shift;
+ if (&update_table_info($table_id)) {
+ return @{$Tables{$table_id}->{'Col_order'}};
+ } else {
+ return ();
+ }
+}
###############################
=pod
-=item &create_table
+=item &create_table()
Inputs:
table description
@@ -516,17 +593,32 @@ Input formats:
table description = {
permanent => 'yes' or 'no',
- columns => {
- colA => {
- type => mysql type,
- restrictions => 'NOT NULL' or empty,
- primary_key => 'yes' or empty,
- auto_inc => 'yes' or empty,
- }
- colB => { .. }
- colZ => { .. }
- },
- column_order => [ colA, colB, ..., colZ],
+ columns => [
+ { name => 'colA',
+ type => mysql type,
+ restrictions => 'NOT NULL' or empty,
+ primary_key => 'yes' or empty,
+ auto_inc => 'yes' or empty,
+ },
+ { name => 'colB',
+ ...
+ },
+ { name => 'colC',
+ ...
+ },
+ ],
+ 'PRIMARY KEY' => (index_col_name,...),
+ KEY => [{ name => 'idx_name',
+ columns => (col1,col2,..),},],
+ INDEX => [{ name => 'idx_name',
+ columns => (col1,col2,..),},],
+ UNIQUE => [{ index => 'yes',
+ name => 'idx_name',
+ columns => (col1,col2,..),},],
+ FULLTEXT => [{ index => 'yes',
+ name => 'idx_name',
+ columns => (col1,col2,..),},],
+
}
Returns:
@@ -543,12 +635,18 @@ sub create_table {
##################################
my @Columns;
my $col_des;
- my $table_id = &get_new_table_id();
+ my $table_id;
+ if (exists($table_des->{'id'})) {
+ $table_id = $table_des->{'id'};
+ } else {
+ $table_id = &get_new_table_id();
+ }
my $tablename = &translate_id($table_id);
my $request = "CREATE TABLE IF NOT EXISTS ".$tablename." ";
- foreach my $column (@{$table_des->{'column_order'}}) {
+ foreach my $coldata (@{$table_des->{'columns'}}) {
+ my $column = $coldata->{'name'};
+ next if (! defined($column));
$col_des = '';
- my $coldata = $table_des->{'columns'}->{$column};
if (lc($coldata->{'type'}) =~ /(enum|set)/) { # 'enum' or 'set'
$col_des.=$column." ".$coldata->{'type'}."('".
join("', '",@{$coldata->{'values'}})."')";
@@ -573,9 +671,39 @@ sub create_table {
# skip blank items.
push (@Columns,$col_des) if ($col_des ne '');
}
- if (exists($table_des->{'fulltext'}) && (@{$table_des->{'fulltext'}})) {
- push (@Columns,'FULLTEXT ('.join(',',@{$table_des->{'fulltext'}}).')');
+ if (exists($table_des->{'PRIMARY KEY'})) {
+ push (@Columns,'PRIMARY KEY ('.join(',',@{$table_des->{'PRIMARY KEY'}})
+ .')');
+ }
+ #
+ foreach my $indextype ('KEY','INDEX') {
+ next if (!exists($table_des->{$indextype}));
+ foreach my $indexdescription (@{$table_des->{$indextype}}) {
+ my $text = $indextype.' ';
+ if (exists($indexdescription->{'name'})) {
+ $text .=$indexdescription->{'name'};
+ }
+ $text .= ' ('.join(',',@{$indexdescription->{'columns'}}).')';
+ push (@Columns,$text);
+ }
}
+ #
+ foreach my $indextype ('UNIQUE','FULLTEXT') {
+ next if (! exists($table_des->{$indextype}));
+ foreach my $indexdescription (@{$table_des->{$indextype}}) {
+ my $text = $indextype.' ';
+ if (exists($indexdescription->{'index'}) &&
+ $indexdescription->{'index'} eq 'yes') {
+ $text .= 'INDEX ';
+ }
+ if (exists($indexdescription->{'name'})) {
+ $text .=$indexdescription->{'name'};
+ }
+ $text .= ' ('.join(',',@{$indexdescription->{'columns'}}).')';
+ push (@Columns,$text);
+ }
+ }
+ #
$request .= "(".join(", ",@Columns).") ";
unless($table_des->{'permanent'} eq 'yes') {
$request.="COMMENT = 'temporary' ";
@@ -603,7 +731,7 @@ sub create_table {
=pod
-=item &get_new_table_id
+=item &get_new_table_id()
Used internally to prevent table name collisions.
@@ -625,7 +753,7 @@ sub get_new_table_id {
=pod
-=item &get_rows
+=item &get_rows()
Inputs: $table_id,$condition
@@ -648,7 +776,13 @@ sub get_rows {
return undef;
}
my $tablename = &translate_id($table_id);
- my $request = 'SELECT * FROM '.$tablename.' WHERE '.$condition;
+ my $request;
+ if (defined($condition) && $condition ne '') {
+ $request = 'SELECT * FROM '.$tablename.' WHERE '.$condition;
+ } else {
+ $request = 'SELECT * FROM '.$tablename;
+ $condition = 'no condition';
+ }
my $sth=$dbh->prepare($request);
$sth->execute();
if ($sth->err) {
@@ -666,7 +800,7 @@ sub get_rows {
=pod
-=item &store_row
+=item &store_row()
Inputs: table id, row data
@@ -721,11 +855,72 @@ sub store_row {
return 1;
}
+###############################
+
+=pod
+
+=item &replace_row()
+
+Inputs: table id, row data
+
+returns undef on error, 1 on success.
+
+Acts like &store_row() but uses the 'REPLACE' command instead of 'INSERT'.
+
+=cut
+
+###############################
+sub replace_row {
+ my ($table_id,$rowdata) = @_;
+ #
+ return undef if (! defined(&connect_to_db()));
+ my $table_status = &check_table($table_id);
+ return undef if (! defined($table_status));
+ if (! $table_status) {
+ $errorstring = "table $table_id does not exist.";
+ return undef;
+ }
+ #
+ my $tablename = &translate_id($table_id);
+ #
+ my $sth;
+ if (exists($Tables{$tablename}->{'row_replace_sth'})) {
+ $sth = $Tables{$tablename}->{'row_replace_sth'};
+ } else {
+ # Build the insert statement handler
+ return undef if (! defined(&update_table_info($table_id)));
+ my $replace_request = 'REPLACE INTO '.$tablename.' VALUES(';
+ foreach (@{$Tables{$tablename}->{'Col_order'}}) {
+ $replace_request.="?,";
+ }
+ chop $replace_request;
+ $replace_request.=")";
+ $sth=$dbh->prepare($replace_request);
+ $Tables{$tablename}->{'row_replace_sth'}=$sth;
+ }
+ my @Parameters;
+ if (ref($rowdata) eq 'ARRAY') {
+ @Parameters = @$rowdata;
+ } elsif (ref($rowdata) eq 'HASH') {
+ foreach (@{$Tables{$tablename}->{'Col_order'}}) {
+ push(@Parameters,$rowdata->{$_});
+ }
+ }
+ $sth->execute(@Parameters);
+ if ($sth->err) {
+ $errorstring = "$dbh ATTEMPTED replace @Parameters RESULTING ERROR:\n".
+ $sth->errstr;
+ return undef;
+ }
+ $debugstring = "Stored row.";
+ return 1;
+}
+
###########################################
=pod
-=item tables_in_db
+=item &tables_in_db()
Returns a list containing the names of all the tables in the database.
Returns undef on error.
@@ -737,25 +932,27 @@ sub tables_in_db {
return undef if (!defined(&connect_to_db()));
my $sth=$dbh->prepare('SHOW TABLES');
$sth->execute();
- if ($sth->err) {
- $errorstring = "$dbh ATTEMPTED:\n".'SHOW TABLES'.
+ $sth->execute();
+ my $aref = $sth->fetchall_arrayref;
+ if ($sth->err()) {
+ $errorstring =
+ "$dbh ATTEMPTED:\n".'fetchall_arrayref after SHOW TABLES'.
"\nRESULTING ERROR:\n".$sth->errstr;
return undef;
}
- my $aref = $sth->fetchall_arrayref;
- my @table_list=();
+ my @table_list;
foreach (@$aref) {
- push @table_list,$_->[0];
+ push(@table_list,$_->[0]);
}
- $debugstring = "Got list of tables in DB: @table_list";
- return @table_list;
+ $debugstring = "Got list of tables in DB: ".join(',',@table_list);
+ return(@table_list);
}
###########################################
=pod
-=item &translate_id
+=item &translate_id()
Used internally to translate a numeric table id into a MySQL table name.
If the input $id contains non-numeric characters it is assumed to have
@@ -778,7 +975,9 @@ sub translate_id {
=pod
-=item &check_table($id)
+=item &check_table()
+
+Input: table id
Checks to see if the requested table exists. Returns 0 (no), 1 (yes), or
undef (error).
@@ -794,7 +993,7 @@ sub check_table {
my @Table_list = &tables_in_db();
my $result = 0;
foreach (@Table_list) {
- if (/^$table_id$/) {
+ if ($_ eq $table_id) {
$result = 1;
last;
}
@@ -809,7 +1008,11 @@ sub check_table {
=pod
-=item &remove_from_table($table_id,$column,$value)
+=item &remove_from_table()
+
+Input: $table_id, $column, $value
+
+Returns: the number of rows deleted. undef on error.
Executes a "delete from $tableid where $column like binary '$value'".
@@ -821,18 +1024,79 @@ sub remove_from_table {
return undef if (!defined(&connect_to_db()));
#
$table_id = &translate_id($table_id);
- my $command = 'DELETE FROM '.$table_id.' WHERE '.$dbh->quote($column).
+ my $command = 'DELETE FROM '.$table_id.' WHERE '.$column.
" LIKE BINARY ".$dbh->quote($value);
my $sth = $dbh->prepare($command);
- $sth->execute();
- if ($sth->err) {
+ unless ($sth->execute()) {
$errorstring = "ERROR on execution of ".$command."\n".$sth->errstr;
return undef;
}
+ $debugstring = $command;
my $rows = $sth->rows;
return $rows;
}
+###########################################
+
+=pod
+
+=item drop_table($table_id)
+
+Issues a 'drop table if exists' command
+
+=cut
+
+###########################################
+
+sub drop_table {
+ my ($table_id) = @_;
+ return undef if (!defined(&connect_to_db()));
+ #
+ $table_id = &translate_id($table_id);
+ my $command = 'DROP TABLE IF EXISTS '.$table_id;
+ my $sth = $dbh->prepare($command);
+ $sth->execute();
+ if ($sth->err) {
+ $errorstring = "ERROR on execution of ".$command."\n".$sth->errstr;
+ return undef;
+ }
+ $debugstring = $command;
+ delete($Tables{$table_id}); # remove any knowledge of the table
+ return 1; # if we got here there was no error, so return a 'true' value
+}
+
+
+
+
+# ---------------------------- convert 'time' format into a datetime sql format
+sub sqltime {
+ my ($sec,$min,$hour,$mday,$mon,$year,$wday,$yday,$isdst) =
+ localtime(&unsqltime($_[0]));
+ $mon++; $year+=1900;
+ return "$year-$mon-$mday $hour:$min:$sec";
+}
+
+sub maketime {
+ my %th=@_;
+ return POSIX::mktime(($th{'seconds'},$th{'minutes'},$th{'hours'},
+ $th{'day'},$th{'month'}-1,
+ $th{'year'}-1900,0,0,$th{'dlsav'}));
+}
+
+
+#########################################
+#
+# Retro-fixing of un-backward-compatible time format
+
+sub unsqltime {
+ my $timestamp=shift;
+ if ($timestamp=~/^(\d+)\-(\d+)\-(\d+)\s+(\d+)\:(\d+)\:(\d+)$/) {
+ $timestamp=&maketime('year'=>$1,'month'=>$2,'day'=>$3,
+ 'hours'=>$4,'minutes'=>$5,'seconds'=>$6);
+ }
+ return $timestamp;
+}
+
1;