[MERGE] added a duplicate operation to the db service.

bzr revid: vmt@openerp.com-20121114121308-3rbf8or8u1y9t0ks
This commit is contained in:
Vo Minh Thu 2012-11-14 13:13:08 +01:00
commit 2e6efe423b
1 changed files with 13 additions and 2 deletions

View File

@ -103,7 +103,7 @@ class db(netsvc.ExportService):
if method in [ 'create', 'get_progress', 'drop', 'dump',
'restore', 'rename',
'change_admin_password', 'migrate_databases',
'create_database' ]:
'create_database', 'duplicate_database' ]:
passwd = params[0]
params = params[1:]
security.check_super(passwd)
@ -152,11 +152,22 @@ class db(netsvc.ExportService):
self.actions[id] = {'clean': False}
_logger.info('CREATE DATABASE %s', db_name.lower())
_logger.info('Create database `%s`.', db_name)
self._create_empty_database(db_name)
_initialize_db(self, id, db_name, demo, lang, user_password)
return True
def exp_duplicate_database(self, db_original_name, db_name):
_logger.info('Duplicate database `%s` to `%s`.', db_original_name, db_name)
db = sql_db.db_connect('postgres')
cr = db.cursor()
try:
cr.autocommit(True) # avoid transaction block
cr.execute("""CREATE DATABASE "%s" ENCODING 'unicode' TEMPLATE "%s" """ % (db_name, db_original_name))
finally:
cr.close()
return True
def exp_get_progress(self, id):
if self.actions[id]['thread'].isAlive():
# return openerp.modules.init_progress[db_name]