本文整理汇总了Python中rethinkdb.db_drop函数的典型用法代码示例。如果您正苦于以下问题:Python db_drop函数的具体用法?Python db_drop怎么用?Python db_drop使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了db_drop函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。
示例1: init
def init(conn, event):
# try to drop table (may or may not exist)
rv = ''
try:
r.db_drop(TIX).run(conn)
rv = 'dropped, then created'
except:
rv = 'created'
r.db_create(TIX).run(conn)
r.db(TIX).table_create(VENU).run(conn)
r.db(TIX).table(VENU).index_create(TS).run(conn)
smap = {}
umap = {}
for x in range(1, CNT + 1):
smap[str(x)] = 'free'
umap[str(x)] = ''
rv += str(r.db(TIX).table(VENU).insert({
ID: 0,
SMAP: smap,
UMAP: umap,
MAX: CNT,
TS: time.time()
}).run(conn))
return rv
开发者ID:phonyphonecall,项目名称:open-lambda,代码行数:27,代码来源:tix.py
示例2: main
def main():
import rethinkdb as r
from rethinkdb.errors import RqlRuntimeError
# Lib para auxilio na insercao de dados de teste
from faker import Factory
fake = Factory.create('pt_BR')
# Conecta ao banco local
r.connect(HOST, PORT).repl()
try:
r.db_drop(DBNAME).run()
except RqlRuntimeError:
pass
# Cria o banco de dados
r.db_create(DBNAME).run()
# Cria a tabela
r.db(DBNAME).table_create(TABLENAME).run()
# Insere os registros na tabela
for frase in range(TOTAL_FRASES):
reg = {
'id': frase,
'frase': fake.text(),
'autor': fake.name()
}
r.db(DBNAME).table(TABLENAME).insert(reg).run()
开发者ID:gilsondev,项目名称:falcon-tutorial,代码行数:30,代码来源:restapidb.py
示例3: main
def main():
# connect rethinkdb
rethinkdb.connect("localhost", 28015, "mysql")
try:
rethinkdb.db_drop("mysql").run()
except:
pass
rethinkdb.db_create("mysql").run()
tables = ["dept_emp", "dept_manager", "titles",
"salaries", "employees", "departments"]
for table in tables:
rethinkdb.db("mysql").table_create(table).run()
stream = BinLogStreamReader(
connection_settings=MYSQL_SETTINGS,
blocking=True,
only_events=[DeleteRowsEvent, WriteRowsEvent, UpdateRowsEvent],
)
# process Feed
for binlogevent in stream:
if not isinstance(binlogevent, WriteRowsEvent):
continue
for row in binlogevent.rows:
if not binlogevent.schema == "employees":
continue
vals = {}
vals = {str(k): str(v) for k, v in row["values"].iteritems()}
rethinkdb.table(binlogevent.table).insert(vals).run()
stream.close()
开发者ID:Affirm,项目名称:python-mysql-replication,代码行数:34,代码来源:rethinkdb_sync.py
示例4: init_database_with_default_tables
def init_database_with_default_tables(args):
"""
Create a new RethinkDB database and initialise (default) tables
:param args: an argparse argument (force)
"""
# Add additional (default) tables here...
def_tables = ['determined_variants', 'strains_under_investigation',
'references', 'reference_features', 'strain_features']
with database.make_connection() as connection:
try:
r.db_create(connection.db).run(connection)
for atable in def_tables:
r.db(connection.db).table_create(atable).run(connection)
except RqlRuntimeError:
print ("Database %s already exists. Use '--force' option to "
"reinitialise the database." % (connection.db))
if args.force:
print "Reinitialising %s" % (connection.db)
r.db_drop(connection.db).run(connection)
r.db_create(connection.db).run(connection)
for atable in def_tables:
r.db(connection.db).table_create(atable).run(connection)
else:
sys.exit(1)
print ("Initalised database %s. %s contains the following tables: "
"%s" % (connection.db, connection.db, ', '.join(def_tables)))
开发者ID:m-emerson,项目名称:BanzaiDB,代码行数:27,代码来源:banzaidb.py
示例5: delete_databases
def delete_databases(dbnames=[]):
b = Bigchain()
for dbname in dbnames:
logger.info('Dropping database: {}'.format(dbname))
try:
r.db_drop(dbname).run(b.conn)
except r.ReqlOpFailedError as e:
logger.info(e.message)
开发者ID:cavacn,项目名称:bigchaindb-examples,代码行数:9,代码来源:bigchaindb_examples.py
示例6: drop_db
def drop_db():
logger.info("Dropping RethinkDB database '{}'...".format(RETHINKDB_NAME))
try:
with get_connection() as conn:
r.db_drop(RETHINKDB_NAME).run(conn)
logger.info("RethinkDB database dropped successfully.")
except r.RqlRuntimeError:
logger.info("Database '{}' does not exist on {}:{}".format(
RETHINKDB_NAME, RETHINKDB_HOST, RETHINKDB_PORT))
开发者ID:chuckSMASH,项目名称:know-it-all,代码行数:9,代码来源:tasks.py
示例7: tearDownClass
def tearDownClass(self):
""" Drops the test database after the classes' tests are finished """
with rethinkdb.connect(host='localhost', port=28015) as conn:
if 'TEST' in rethinkdb.db_list().run(conn):
rethinkdb.db_drop('TEST').run(conn)
try:
self.rdb.close()
except AttributeError:
pass
开发者ID:DAPMElab,项目名称:TBWA_Vendor_Portal,代码行数:9,代码来源:template.py
示例8: drop_database
def drop_database():
"""
Deletes the RethinkDB database
"""
try:
with get_connection() as conn:
rethink.db_drop(DEFAULT_DB_NAME).run(conn)
except (RqlRuntimeError, RqlDriverError) as err:
print(err.message)
开发者ID:pombredanne,项目名称:pywebhooks,代码行数:9,代码来源:drop.py
示例9: db_drop
def db_drop():
connection = r.connect(host=RDB_HOST, port=RDB_PORT)
try:
r.db_drop(DB).run(connection)
print "Database dropped."
except:
print "Error in dropping database"
finally:
connection.close()
开发者ID:prakhar1989,项目名称:instabase,代码行数:9,代码来源:app.py
示例10: DropTable
def DropTable(name, conn):
'''Dropping tables -- for clean-up.'''
try:
r.db_drop(name).run(conn)
return True
except Exception as e:
print "Could not drop table `%s`" % name
return False
开发者ID:luiscape,项目名称:hio-setup,代码行数:10,代码来源:setup_db.py
示例11: fin
def fin():
print('Deleting `{}` database'.format(db_name))
get_conn().repl()
try:
r.db_drop(db_name).run()
except r.ReqlOpFailedError as e:
if e.message != 'Database `{}` does not exist.'.format(db_name):
raise
print('Finished deleting `{}`'.format(db_name))
开发者ID:galtys,项目名称:bigchaindb,代码行数:10,代码来源:conftest.py
示例12: init_db
def init_db():
"""
Initialize the database.
"""
with connect() as con:
try:
r.db_drop('awe').run(con)
except r.ReqlOpFailedError:
pass
r.db_create('awe').run(con)
开发者ID:starcraftman,项目名称:new-awesome,代码行数:10,代码来源:common.py
示例13: test_configure
def test_configure(self):
# r.table_drop(self.table_name).run(self.connection)
r.db_drop(self.db_name).run(self.connection)
self.db.configure()
db_exists = r.db_list().contains(self.db_name).run(self.connection)
self.assertTrue( db_exists )
table_exists = r.db(self.db_name).table_list().contains(self.table_name).run(self.connection)
self.assertTrue( table_exists )
开发者ID:TripleDogDare,项目名称:RadioWCSpy,代码行数:10,代码来源:test_db_rethink.py
示例14: rethink_unique_db
def rethink_unique_db(rethink_server_sess):
""" Starts up a session-scoped server, and returns a connection to
a unique database for the life of a single test, and drops it after
"""
dbid = uuid.uuid4().hex
conn = rethink_server_sess.conn
rethinkdb.db_create(dbid).run(conn)
conn.use(dbid)
yield conn
rethinkdb.db_drop(dbid).run(conn)
开发者ID:eeaston,项目名称:pkglib,代码行数:10,代码来源:rethink.py
示例15: real_stock_data_load
def real_stock_data_load(data, connection):
for db in list(r.db_list().run(connection)):
if db == u"rethinkdb":
# This db is special and can't be deleted.
continue
r.db_drop(db).run(connection)
for db_name, db_data in iteritems(data['dbs']):
r.db_create(db_name).run(connection)
for table_name, table_data in iteritems(db_data['tables']):
r.db(db_name).table_create(table_name).run(connection)
r.db(db_name).table(table_name).insert(table_data).run(connection)
开发者ID:scivey,项目名称:mockthink,代码行数:11,代码来源:common.py
示例16: db_reset
def db_reset():
if yn_choice("Are you sure you wish to reset the Database?\nAll data will be lost and this cannot be undone.", 'n'):
connection = r.connect(host=RDB_HOST, port=RDB_PORT, db=CP2020_DB)
try:
r.db_drop(CP2020_DB).run(connection)
print ('Database deleted')
except RqlRuntimeError:
print ('Database could not be deleted')
finally:
connection.close()
db_setup()
开发者ID:puhlenbruck,项目名称:CPPA,代码行数:11,代码来源:dbcontrols.py
示例17: init_tables
def init_tables():
"""
Create the tables we are going to use
"""
global connection, tables
print "Creating databases/tables...",
sys.stdout.flush()
try:
r.db_drop("test").run(connection)
except r.errors.RqlRuntimeError, e:
pass
开发者ID:B-sound,项目名称:rethinkdb,代码行数:12,代码来源:test.py
示例18: setUpClass
def setUpClass(cls):
cls.connection = r.connect(host=DB.RDB_HOST, port=DB.RDB_PORT, db=DB_AWS_TEST)
try:
# Create the DB tables we need
DB.Database.create_db_structure(DB_AWS_TEST)
test_conf = TestingConfig(DB_AWS_TEST)
cls.app = app.create_app(test_conf).test_client()
# print 'Set-up DONE. DB-name: {db_name}'.format(db_name=DB_AWS_TEST)
except RqlRuntimeError:
# print 'The test-database already exist. Will remove it, and then re-run the test!'
r.db_drop(DB_AWS_TEST).run(cls.connection)
cls.setUpClass()
开发者ID:jwanglof,项目名称:automatic_watering_system,代码行数:12,代码来源:test_base.py
示例19: drop_database
def drop_database(self):
"""Drop the db for the application.
If the db exists, log a warning.
Returns:
None
"""
dbs = r.db_list().run(self.connection)
if self.db in dbs:
r.db_drop(self.db).run(self.connection)
开发者ID:JeffHeard,项目名称:sondra,代码行数:12,代码来源:__init__.py
示例20: db_init
def db_init(dest_ip):
# connect
conn = r.connect(dest_ip, 28015)
state = ''
try:
r.db_drop('authentication').run(conn)
state = 'deleted, then created'
except:
state = 'created'
r.db_create('authentication').run(conn)
r.db('authentication').table_create('user', primary_key = 'account').run(conn)
开发者ID:sherlockwu,项目名称:OL_Authentication,代码行数:12,代码来源:setup.py
注:本文中的rethinkdb.db_drop函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论