In recent years, we have seen a growing interest in database management systems that differ from the traditional relational model. At the heart of this is the concept of NoSQL, a term used collectively to denote database software that does not use the Structured Query Language (SQL) to interact with the database. One of the more notable NoSQL projects out there is MongoDB, an open source document-oriented database that stores data in collections of JSON-like documents. What sets MongoDB apart from other NoSQL databases is its powerful document-based query language, which makes the transition from a relational database to MongoDB easy because the queries translate quite easily.
This new class of databases seems to solve many of the bottlenecks in MySql and other relational databases. It will give you shear performance, self replication and scalability at not cost because it open source. MongoDB has plenty of drivers for other scripting and high-level languages I use PHP so I download the PHP driver. You can see the supported list here: http://www.mongodb.org/display/DOCS/Drivers. In this blog I convert a MySQL database using PHP to MongoDB.
First you install MongoDB, you can do it by checking the previous blog. Check this link
Then we run the script to convert a Mysql DB to Mongodb.
create a new file called MySqltoMongodb.php , In that file please copy paste the below contants (please give your Mysql DB details as well as your Mongodb details)
-
<?php
-
// mysql settings
-
$mydb = “database”;
-
$myconn = mysql_connect(‘localhost’,’user’,’password’);
-
$setmydb = mysql_select_db( $mydb );
-
$mytables = getMyTables( $mydb );
-
//mongo db settings
-
$modb = “database”;
-
$moConnect=”mongodb://user:password@localhost”;
-
function getMyTables( $dbname ) {
-
$tables = array();
-
$sql = mysql_query(“SHOW TABLES FROM $dbname “) or die(“Error getting tables from $dbname”);
-
if( mysql_num_rows( $sql ) > 0 ) {
-
while( $table = mysql_fetch_array( $sql ) ) {
-
$explain = explainMyTable( $table[0] );
-
$tables[$table[0]] = $explain;
-
}
-
}
-
return $tables;
-
}
-
function explainMyTable( $tbname ) {
-
$explain = array();
-
$sql = mysql_query(“EXPLAIN $tbname”) or die(“Error getting table structure”);
-
$i = 0;
-
while( $get = mysql_fetch_array( $sql ) ) {
-
array_push( $explain, $get[0] );
-
$i++;
-
}
-
return $explain;
-
}
-
function checkEncode($string) {
-
if( !mb_check_encoding($string,’UTF-8′)) {
-
return mb_convert_encoding($string,’UTF-8′,’ISO-8859-1′);
-
} else {
-
return $string;
-
}
-
}
-
try {
-
$moconn = new Mongo($moConnect);
-
$modb = $moconn->selectDB( $modb );
-
} catch(MongoConnectionException $e) {
-
die($e.”Problem during mongodb initialization. Please start mongodb server.”);
-
}
-
foreach( $mytables as $table => $struct ) {
-
$sql = mysql_query(“SELECT * FROM $table LIMIT 0 , 500000″) or die( mysql_error() );
-
$count = mysql_num_rows( $sql );
-
// Starts new collection on mongodb
-
$collection = $modb->$table;
-
// If it has content insert all content
-
if( $count > 0 ) {
-
while( $info = mysql_fetch_array( $sql, MYSQL_NUM )) {
-
$infosize = count( $info );
-
$mosql = array();
-
for( $i=0; $i < $infosize; $i++ ) {
-
if(!empty($struct[$i]))
-
$mosql[$struct[$i]] = checkEncode($info[$i]);
-
}
-
$collection->insert($mosql);
-
}
-
// Only create a new entry empty
-
} else {
-
for( $i=0; $i < $infosize; $i++ ) {
-
if(!empty($struct[$i]))
-
$mosql[$struct[$i]] = ”;
-
}
-
$collection->insert($mosql);
-
}
-
}
-
echo “Done! Please, check your MongoDB collection!”;
-
?>
Now fire up your browser and launch the page. If all goes well you should see
“Done! Please, check your MongoDB collection!”
After running this script check your Mongo db collection, in that you can see your Mysql Table. However we haven’t done it on a large system, we are planning to do the same on a huge Postgres Sql system soon.
