Mirroristas/bigchaindb
2
0
Fork 0
mirror of https://github.com/bigchaindb/bigchaindb.git synced 2024-10-13 13:34:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

Split the setting of the database initialization from the initialization of the genesis block of the bigchainDB

Browse Source
This commit is contained in:
najla 2016-08-07 22:11:04 +02:00 committed by Sylvain Bellemare
parent ac6249b42f
commit fc54aef181
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
bigchaindb/db/utils.py
View File

@ -161,10 +161,7 @@ def create_votes_secondary_index(conn, dbname):
r.db(dbname).table('votes').index_wait().run(conn) r.db(dbname).table('votes').index_wait().run(conn)
def init(): def init_database():
# Try to access the keypair, throws an exception if it does not exist
b = bigchaindb.Bigchain()
conn = get_conn() conn = get_conn()
dbname = get_database_name() dbname = get_database_name()
create_database(conn, dbname) create_database(conn, dbname)
@ -172,10 +169,18 @@ def init():
table_names = ['bigchain', 'backlog', 'votes'] table_names = ['bigchain', 'backlog', 'votes']
for table_name in table_names: for table_name in table_names:
create_table(conn, dbname, table_name) create_table(conn, dbname, table_name)
create_bigchain_secondary_index(conn, dbname) create_bigchain_secondary_index(conn, dbname)
create_backlog_secondary_index(conn, dbname) create_backlog_secondary_index(conn, dbname)
create_votes_secondary_index(conn, dbname) create_votes_secondary_index(conn, dbname)
def init():
# Try to access the keypair, throws an exception if it does not exist
b = bigchaindb.Bigchain()
init_database()
logger.info('Create genesis block.') logger.info('Create genesis block.')
b.create_genesis_block() b.create_genesis_block()
logger.info('Done, have fun!') logger.info('Done, have fun!')
@ -184,9 +189,9 @@ def init():
def drop(assume_yes=False): def drop(assume_yes=False):
conn = get_conn() conn = get_conn()
dbname = bigchaindb.config['database']['name'] dbname = bigchaindb.config['database']['name']
if assume_yes: if assume_yes:
response = 'y' response = 'y'
else: else:
response = input('Do you want to drop `{}` database? [y/n]: '.format(dbname)) response = input('Do you want to drop `{}` database? [y/n]: '.format(dbname))
@ -197,5 +202,6 @@ def drop(assume_yes=False):
logger.info('Done.') logger.info('Done.')
except r.ReqlOpFailedError: except r.ReqlOpFailedError:
raise exceptions.DatabaseDoesNotExist('Database `{}` does not exist'.format(dbname)) raise exceptions.DatabaseDoesNotExist('Database `{}` does not exist'.format(dbname))
else: else:
logger.info('Drop aborted') logger.info('Drop aborted')