Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- ###########################
- # Script for converting #
- # mongoDB to mySql #
- # Coded by Atul Yadav #
- ###########################
- #!/usr/bin/python
- from pymongo import MongoClient
- import MySQLdb
- import unicodedata
- #################################
- # mongoDb Server Details #
- #################################
- mongoServer = raw_input("Enter MongoDb Server Address = ") # address of mongo server
- mongoPort = int(raw_input("Enter MongoDb Server Port Number = ")) # mongo port nubmer
- mongoDatabase = raw_input("Enter MongoDb Database Name = ") # mongo database name
- mongoCollectionName= mongoDatabase = raw_input("Enter MongoDb Database Collection Name = ") # mongo collection name
- #################################
- # mySql Server Details #
- #################################
- mySqlServer = raw_input("Enter mySql Server Address = ") # address of mySql Server
- mySqlUser = raw_input("Enter mySql User Name = ") # mySql User name
- mySqlPassword = raw_input("Enter mySql User Password = ") # mySql User password
- mySqlDatabase = raw_input("Enter mySql Database Name = ") # name of mySql Database
- mySqlTable = raw_input("Enter mySql Database Table Name = ") #name of mySql Table
- #################################
- # Connection to mongo #
- #################################
- print 'Trying to connect to MongoDB Server.... Please Wait...'
- try:
- mongoConnection = MongoClient(mongoServer,mongoPort)
- mongoDB = mongoConnection[mongoDatabase]
- mongoCollection = mongoDB[mongoCollectionName]
- if mongoConnection.server_info():
- print 'Establishing connection to mongoDB successful :)'
- else:
- pass
- except:
- print 'Error Connecting MongoDB. Please Check Connection Settings.'
- #################################
- # Connection to mySql #
- #################################
- print 'Trying to connect to mySql Server.... Please Wait...'
- try:
- sqlConnection = MySQLdb.connect(mySqlServer,mySqlUser,mySqlPassword,mySqlDatabase)
- sqlCursor = sqlConnection.cursor()
- if sqlConnection.open:
- print 'Establishing connection to mySql Server successful :)'
- else:
- pass
- except:
- print 'Error Connecting mySql Server. Please Check Connection Settings.'
- #################################
- # Data Dumping #
- #################################
- print 'Dumping Mongo Data to Sql .....'
- try:
- document = mongoCollection.find()
- keyList = []
- valueList = []
- for details in document:
- del details['_id']
- cols = []
- values = []
- for key, value in details.items():
- key = key.encode('ascii')
- if isinstance(value,unicode):
- value = value.encode('ascii')
- cols.append(key)
- values.append(value)
- q = '''insert into profile ({}) VALUES {}''' .format(','.join(cols), tuple(values))
- print q
- sqlCursor.execute(q)
- sqlConnection.commit()
- keyList = []
- valueList = []
- print 'Done'
- sqlConnection.close()
- except:
- print 'Error Dumping Data'
- #################################
- print '#### Thanks for Using ####'
Add Comment
Please, Sign In to add comment