home *** CD-ROM | disk | FTP | other *** search
/ H4CK3R 4 / hacker04 / 04_HACK04.ISO / src / PHP / uploadodbc.php3.txt < prev    next >
Encoding:
Text File  |  2002-05-06  |  4.7 KB  |  166 lines
  1. Upload ODBC table
  2.  
  3. This program allows you to upload an ODBC ressource - i.e. an MS-Access database to a MySQL server. The table must already exist on MySQL It will figure out which fields are defined in the MySQL table and then upload the coresponding field from the ODBC ressource. If you give it no arguments. It will show you a list of tables in the MySQL database. 
  4.  
  5.  
  6.  
  7.  
  8. <?php 
  9. /* 
  10.  * This include file defines the functions html_header and html_footer 
  11.  */ 
  12. require( "design.inc"); 
  13. $mysqldb =  "concord"; 
  14.  
  15. function nonfatal_error($message) 
  16. { 
  17.     printf( "<H1>%s</H1>\n",$message); 
  18. } 
  19.  
  20.  
  21. function upload_records($odbcfd,$myfd,$mysqldb,$table) 
  22. { 
  23. /* 
  24. * Figure out which columns the mysql database has 
  25. */ 
  26.     $fieldlist = mysql_list_fields($mysqldb,$table); 
  27.     $numof  = mysql_num_fields($fieldlist); 
  28.     for($i = 0; $i < $numof; $i++) 
  29.     { 
  30.         $fieldname = mysql_field_name($fieldlist,$i); 
  31.         if($i == 0) 
  32.             $columnlist = $fieldname; 
  33.         else 
  34.             $columnlist = $columnlist .  "," . $fieldname; 
  35.         $fieldtype = mysql_field_type($fieldlist,$i); 
  36.         switch($fieldtype) 
  37.         { 
  38.         case  "string": 
  39.         case  "datetime": 
  40.             $fieldquotes[$fieldname] =  "'"; 
  41.             break; 
  42.         default: 
  43.             $fieldquotes[$fieldname] =  ""; 
  44.             break; 
  45.         } 
  46.     } 
  47. /* 
  48. * Query the ODBC database and loop through the result. 
  49. */ 
  50.     $res = odbc_exec($odbcfd, "SELECT * FROM $table"); 
  51.     if($res == 0) 
  52.     { 
  53.         nonfatal_error( "Couldn't exec SELECT statement on ODBC database"); 
  54.         return(0); 
  55.     } 
  56. /* 
  57. * Now we know we can query the ODBC database we can delete the records from 
  58. the Mysql 
  59. * database 
  60. */ 
  61.     mysql_db_query($mysqldb, "DELETE FROM $table",$myfd); 
  62.     $rowinx = 0; 
  63.     while(odbc_fetch_row($res)) 
  64.     { 
  65. /* 
  66. * Generate the SQL INSERT STATEMENT 
  67. */ 
  68.         for($i = 0; $i < $numof; $i++) 
  69.         { 
  70.             $fieldname = mysql_field_name($fieldlist,$i); 
  71.             if($i == 0) 
  72.                 $vallist = $fieldquotes[$fieldname] . 
  73.                    addslashes(odbc_result($res,$fieldname)) . 
  74.                    $fieldquotes[$fieldname] ; 
  75.             else 
  76.                 $vallist = $vallist .  "," . $fieldquotes[$fieldname] . 
  77.                    addslashes(odbc_result($res,$fieldname)) . 
  78.                    $fieldquotes[$fieldname] ; 
  79.         } 
  80.         $cmd =  "INSERT INTO $table ($columnlist) VALUES ($vallist)"; 
  81.     if($rowinx % 10 == 0) 
  82.         echo  "<br>"; 
  83.     printf( "%06s\n",$rowinx); 
  84.         if(mysql_db_query($mysqldb,$cmd,$myfd) == 0) 
  85.         { 
  86.             nonfatal_error(mysql_error()); 
  87.         } 
  88.         $rowinx++; 
  89.     } 
  90.     return(1); 
  91. } 
  92.  
  93. /*----------------------------------------------------------------- 
  94. * Start of the program 
  95. */ 
  96.  
  97. /* 
  98. * Connect to the MySQL server 
  99. */ 
  100. $myfd = mysql_connect( "atilia", "guest", "xxxx"); 
  101. if($myfd <= 0) 
  102. { 
  103.     nonfatal_error( "Couldn't open MySQL database"); 
  104.     exit($myfd); 
  105. } 
  106. /* 
  107. * Connect to the ODBC ressource. 
  108. * The DSN must be defined in the executing computer's ODBC tables 
  109. */ 
  110. $odbcfd = odbc_connect( "ConcAccess", "x", "e"); 
  111. if($odbcfd <= 0) 
  112. { 
  113.     nonfatal_error( "Couldn't open ODBC database"); 
  114.     exit($odbcfd); 
  115. } 
  116. function list_tables($mysqldb) 
  117. { 
  118.     echo  "<UL>\n"; 
  119.     $tables= mysql_list_tables($mysqldb); 
  120.     for($i = 0; $i < mysql_num_rows($tables);$i++) 
  121.     { 
  122.         printf( "<LI>Upload table <A HREF=\"upload.php3?table=%s\">%s</A>\n", 
  123.             mysql_tablename($tables,$i), 
  124.             mysql_tablename($tables,$i)); 
  125.     } 
  126.     echo  "</UL>\n"; 
  127. } 
  128. switch ($table) 
  129. { 
  130. case  "": 
  131.     html_header( "Update Database on mysql"); 
  132. ?> 
  133. <P>This page allows you to upload tables from the MS-Access database to the 
  134. database 
  135. on the webserver. There <I>might</I> be some uploading errors. This is the 
  136. reason 
  137. you can only upload one table at a time. You should select a table and then 
  138. look at the 
  139. result for errors.</P> 
  140. <?php 
  141.     list_tables($mysqldb); 
  142.     break; 
  143. default: 
  144.     html_header( "Uploading $table"); 
  145.     echo ( "Row ## Row ## Row ## Row ## Row ## Row ## Row ## Row ## Row ## 
  146. Row ##<br>\n"); 
  147.     $tables= mysql_list_tables($mysqldb); 
  148.     $dotable=0; 
  149.     for($i = 0; $i < mysql_num_rows($tables); $i++) 
  150.         if(mysql_tablename($tables,$i) == $table) 
  151.         { 
  152.              $dotable=1; 
  153.         } 
  154.     if($dotable == 1) 
  155.         upload_records($odbcfd,$myfd,$mysqldb,$table); 
  156.     else 
  157.         nonfatal_error( "There was no such table"); 
  158.  
  159.     list_tables($mysqldb); 
  160.     break; 
  161. } 
  162. odbc_close($odbcfd); 
  163. mysql_close($myfd); 
  164. html_footer(); 
  165. ?> 
  166.