--- loncom/interface/lonmysql.pm	2004/07/21 21:01:04	1.21
+++ loncom/interface/lonmysql.pm	2004/08/20 01:27:05	1.24
@@ -1,7 +1,7 @@
 # The LearningOnline Network with CAPA
 # MySQL utility functions
 #
-# $Id: lonmysql.pm,v 1.21 2004/07/21 21:01:04 matthew Exp $
+# $Id: lonmysql.pm,v 1.24 2004/08/20 01:27:05 matthew Exp $
 #
 # Copyright Michigan State University Board of Trustees
 #
@@ -45,7 +45,7 @@ sub set_mysql_user_and_password {
             $mysqluser = 'www';
             $mysqlpassword = $Apache::lonnet::perlvar{'lonSqlAccess'};
         } else {
-            $mysqluser = 'fuck';
+            $mysqluser = '';
             $mysqlpassword = '';
         }
     }
@@ -619,7 +619,7 @@ Returns:
 sub create_table {
     return undef if (!defined(&connect_to_db($dbh)));
     my ($table_des)=@_;
-    my $request = &build_table_creation_request($table_des);
+    my ($request,$table_id) = &build_table_creation_request($table_des);
     #
     # Execute the request to create the table
     #############################################
@@ -629,15 +629,6 @@ sub create_table {
             $dbh->errstr();
         return undef;
     }
-    #
-    # Set up the internal bookkeeping
-    #############################################
-    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);
     delete($Tables{$tablename}) if (exists($Tables{$tablename}));
     return undef if (! defined(&update_table_info($table_id)));
@@ -770,7 +761,7 @@ sub build_table_creation_request {
         $request.="COMMENT = 'temporary' ";
     } 
     $request .= "TYPE=MYISAM";
-    return $request;
+    return $request,$table_id;
 }
 
 ###############################
@@ -901,6 +892,58 @@ sub store_row {
     return 1;
 }
 
+
+###############################
+
+=pod
+
+=item &bulk_store_rows()
+
+Inputs: table id, [columns],[[row data1].[row data2],...]
+
+returns undef on error, 1 on success.
+
+=cut
+
+###############################
+sub bulk_store_rows {
+    my ($table_id,$columns,$rows) = @_;
+    # 
+    return undef if (! defined(&connect_to_db()));
+    my $dbh = &get_dbh();
+    return undef if (! defined($dbh));
+    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 $request = 'INSERT IGNORE INTO '.$tablename.' ';
+    if (defined($columns) && ref($columns) eq 'ARRAY') {
+        $request .= join(',',@$columns).' ';
+    }
+    if (! defined($rows) || ref($rows) ne 'ARRAY') {
+        $errorstring = "no input rows given.";
+        return undef;
+    }
+    $request .= 'VALUES ';
+    foreach my $row (@$rows) {
+        # avoid doing row stuff here...
+        $request .= '('.join(',',@$row).'),';
+    }
+    $request =~ s/,$//;
+    $dbh->do($request);
+    if ($dbh->err) {
+        $errorstring = 'Attempted '.$/.$request.$/.'Got error '.$dbh->errstr();
+        return undef;
+    }
+    return 1;
+}
+
+
 ###############################
 
 =pod