Difference between revisions of "CSC220 testSql.php"

From dftwiki3
Jump to: navigation, search
Line 1: Line 1:
 
--[[User:Thiebaut|D. Thiebaut]] 21:28, 13 October 2010 (UTC)
 
--[[User:Thiebaut|D. Thiebaut]] 21:28, 13 October 2010 (UTC)
  
Edited by/on --[[User:Thiebaut|D. Thiebaut]] 11:50, 18 October 2010 (UTC)<br />
 
Edited by/on --[[User:Thiebaut|D. Thiebaut]] 23:44, 28 October 2010 (UTC)
 
 
----
 
----
  
 
<code><pre>
 
<code><pre>
 +
 
// testSql.php
 
// testSql.php
 
// D. Thiebaut
 
// D. Thiebaut
Line 16: Line 15:
 
// Modification 10/18/10: Julia Burch
 
// Modification 10/18/10: Julia Burch
 
// $result = mysql_select_db($database);
 
// $result = mysql_select_db($database);
 
+
// Version 3 (10/30/10)
  
 
//----------------------------------------------------------
 
//----------------------------------------------------------
 
// Globals.  Enter your user information here
 
// Globals.  Enter your user information here
 
//----------------------------------------------------------
 
//----------------------------------------------------------
$user        = "220a";   // EDIT THIS LINE!
+
include 'accessinfo.php';   // contains $user, $password, $host, $database, and $sqlFile
$passwd      = "xxxxxx";      // EDIT THIS LINE TOO!
+
 
$host       = "xgridmac.dyndns.org";
 
$database   = "220a_xxxxxx";  // EDIT THIS LINE AS WELL!
 
$sqlFile     = "test.sql";
 
  
 
//----------------------------------------------------------
 
//----------------------------------------------------------
Line 39: Line 35:
 
   }
 
   }
 
   if ( $result ===False ) {
 
   if ( $result ===False ) {
     print "query unsuccessful\n" ;
+
     print "query unsuccessful: " . mysql_error() . "\n" ;
 
     return;
 
     return;
 
   }
 
   }
Line 65: Line 61:
  
 
//--- connect ---
 
//--- connect ---
mysql_connect( $host, $user, $passwd ) or die( "Unable to connect to db\n\n" );
+
$link = mysql_connect( $host, $user, $passwd );
print "==> Connected to database\n";
+
if ( !$link )
 +
  die( "Unable to connect to db\n" . mysql_error() . "\n" );
 +
print "==> Connected to server\n";
  
 
//--- select database ---
 
//--- select database ---
 
// Modification J. Burch 10/18/10
 
// Modification J. Burch 10/18/10
 
$result = mysql_select_db($database);
 
$result = mysql_select_db($database);
 +
if ( ! $result )
 +
  die( "unable to select database " . $database . "\n" . mysql_error() .  "\n" );
  
 +
print "--> connected to " . $database . "\n";
  
 
//--- get mysql file ---
 
//--- get mysql file ---
Line 78: Line 79:
 
//--- remove comments.  Comments start a line with '--' ---
 
//--- remove comments.  Comments start a line with '--' ---
 
$lines = explode( "\n", $oneLine );
 
$lines = explode( "\n", $oneLine );
//$newLines = array();
 
//foreach ( $lines as $line ) {
 
//  if ( strpos( $line, "--" )===False || strpos( $line, "--" )!=0 )
 
//    $newLines[] = $line;
 
//}
 
 
//--- split at ; ---
 
//$oneLine = implode( " ", $newLines );
 
//$lines = explode( ";", $oneLine );
 
  
 
//--- run each query on the SQL server ---
 
//--- run each query on the SQL server ---
Line 97: Line 89:
 
     $currentQuery .= $queryPart;
 
     $currentQuery .= $queryPart;
 
     if ( strchr( $queryPart, ";" )!== False ) {
 
     if ( strchr( $queryPart, ";" )!== False ) {
      //print "\n\n=========================================================\n";
 
 
       $result = mysql_query( $currentQuery );
 
       $result = mysql_query( $currentQuery );
 
       displayQueryResult( "", $result );
 
       displayQueryResult( "", $result );
Line 110: Line 101:
  
 
?>
 
?>
 
  
  

Revision as of 09:38, 30 October 2010

--D. Thiebaut 21:28, 13 October 2010 (UTC)


 
// testSql.php
// D. Thiebaut
// A simple php program that reads a file containing sql queries
// and issues them, one at a time to the database server on 
// xgridmac.
// The queries are executed, their status displayed (successful,
// unsuccessful), and the result of their output (if any) is also
// displayed on the screen.
// Modification 10/18/10: Julia Burch
// $result = mysql_select_db($database);
// Version 3 (10/30/10)

//----------------------------------------------------------
// Globals.  Enter your user information here
//----------------------------------------------------------
include 'accessinfo.php';    // contains $user, $password, $host, $database, and $sqlFile


//----------------------------------------------------------
// display the result of the query
//----------------------------------------------------------
function displayQueryResult( $caption, $result ) {
  //print "\n---------------------------------------------------------\n";
  print "===> Result of query: ". $caption . "\n";
  //var_dump( $result );
  if ( $result === True ) {
    print "query successful\n";
    return;
  }
  if ( $result ===False ) {
    print "query unsuccessful: " . mysql_error() . "\n" ;
    return;
  }

  while ( $row = mysql_fetch_array( $result, MYSQL_NUM ) ) {
    for ( $i=0; $i < count( $row ); $i++ )
      print "$row[$i]\t";
    print "\n";
  }
}

//----------------------------------------------------------
// removeComments:
//----------------------------------------------------------
function removeComments( $s ) {
   $good = explode( "--", $s );
   if ( count( $good )==0 )
      return "";
   return $good[0];
}

//----------------------------------------------------------
// Run file of SQL queries on MySQL host and report results
//----------------------------------------------------------

//--- connect ---
$link = mysql_connect( $host, $user, $passwd );
if ( !$link ) 
   die( "Unable to connect to db\n" . mysql_error() . "\n" );
print "==> Connected to server\n";

//--- select database ---
// Modification J. Burch 10/18/10
$result = mysql_select_db($database);
if ( ! $result ) 
   die( "unable to select database " . $database . "\n" . mysql_error() .  "\n" );

print "--> connected to " . $database . "\n";

//--- get mysql file ---
$oneLine = file_get_contents( $sqlFile );

//--- remove comments.  Comments start a line with '--' ---
$lines = explode( "\n", $oneLine );

//--- run each query on the SQL server ---
$currentQuery = "";
foreach( $lines as $line ) {
  printf( $line . "\n" );
  $line = trim( $line );
  $queryPart = removeComments( $line );
  if ( strlen( $queryPart )!= 0 )
     $currentQuery .= $queryPart;
     if ( strchr( $queryPart, ";" )!== False ) {
       $result = mysql_query( $currentQuery );
       displayQueryResult( "", $result );
       $currentQuery = "";
       printf( "\n" );
     }
  
}

//--- done.  close connection ---
mysql_close();

?>