Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
sys.exit(11)
if XSD is None:
print('ERROR: -s /path/to/file.xsd is a required argument')
sys.exit(12)
if COMMAND == 'setup_db':
try:
admin.setup_db(DATABASE, TABLE, HOME)
except Exception as err:
print(err)
print('ERROR: DB creation error. Database tables already exist')
print('Delete tables or database to reinitialize')
elif COMMAND == 'load_records':
admin.load_records(CONTEXT, DATABASE, TABLE, XML_DIRPATH, RECURSIVE, FORCE_CONFIRM)
elif COMMAND == 'export_records':
admin.export_records(CONTEXT, DATABASE, TABLE, XML_DIRPATH)
elif COMMAND == 'rebuild_db_indexes':
admin.rebuild_db_indexes(DATABASE, TABLE)
elif COMMAND == 'optimize_db':
admin.optimize_db(CONTEXT, DATABASE, TABLE)
elif COMMAND == 'refresh_harvested_records':
admin.refresh_harvested_records(CONTEXT, DATABASE, TABLE, URL)
elif COMMAND == 'gen_sitemap':
admin.gen_sitemap(CONTEXT, DATABASE, TABLE, URL, OUTPUT_FILE)
elif COMMAND == 'post_xml':
print(admin.post_xml(CSW_URL, XML, TIMEOUT))
elif COMMAND == 'get_sysprof':
print(admin.get_sysprof())
elif COMMAND == 'validate_xml':
admin.validate_xml(XML, XSD)
elif COMMAND == 'delete_records':
if not FORCE_CONFIRM:
available_commands = ['setup_db',
'get_sysprof',
'load_records',
'export_records',
'delete_records',
'list_layers',
'optimize_db',
'reindex']
if COMMAND not in available_commands:
LOGGER.error('pycsw supports only the following commands: %s' % available_commands)
sys.exit(1)
if COMMAND == 'setup_db':
pycsw_admin.setup_db(database, table, home)
elif COMMAND == 'optimize_db':
context = config.StaticContext()
pycsw_admin.optimize_db(context, database, table)
elif COMMAND == 'reindex':
if not catalog_slug:
LOGGER.error('Undefined catalog slug in command line input')
sys.exit(1)
if not check_index_exists(catalog_slug):
create_index(catalog_slug)
re_index_layers(catalog_slug)
elif COMMAND == 'get_sysprof':
LOGGER.debug(pycsw_admin.get_sysprof())
if XML is None:
print('ERROR: -x /path/to/file.xml is a required argument')
sys.exit(11)
if XSD is None:
print('ERROR: -s /path/to/file.xsd is a required argument')
sys.exit(12)
if COMMAND == 'setup_db':
try:
admin.setup_db(DATABASE, TABLE, HOME)
except Exception as err:
print(err)
print('ERROR: DB creation error. Database tables already exist')
print('Delete tables or database to reinitialize')
elif COMMAND == 'load_records':
admin.load_records(CONTEXT, DATABASE, TABLE, XML_DIRPATH, RECURSIVE, FORCE_CONFIRM)
elif COMMAND == 'export_records':
admin.export_records(CONTEXT, DATABASE, TABLE, XML_DIRPATH)
elif COMMAND == 'rebuild_db_indexes':
admin.rebuild_db_indexes(DATABASE, TABLE)
elif COMMAND == 'optimize_db':
admin.optimize_db(CONTEXT, DATABASE, TABLE)
elif COMMAND == 'refresh_harvested_records':
admin.refresh_harvested_records(CONTEXT, DATABASE, TABLE, URL)
elif COMMAND == 'gen_sitemap':
admin.gen_sitemap(CONTEXT, DATABASE, TABLE, URL, OUTPUT_FILE)
elif COMMAND == 'post_xml':
print(admin.post_xml(CSW_URL, XML, TIMEOUT))
elif COMMAND == 'get_sysprof':
print(admin.get_sysprof())
elif COMMAND == 'validate_xml':
admin.validate_xml(XML, XSD)
print('ERROR: -s /path/to/file.xsd is a required argument')
sys.exit(12)
if COMMAND == 'setup_db':
try:
admin.setup_db(DATABASE, TABLE, HOME)
except Exception as err:
print(err)
print('ERROR: DB creation error. Database tables already exist')
print('Delete tables or database to reinitialize')
elif COMMAND == 'load_records':
admin.load_records(CONTEXT, DATABASE, TABLE, XML_DIRPATH, RECURSIVE, FORCE_CONFIRM)
elif COMMAND == 'export_records':
admin.export_records(CONTEXT, DATABASE, TABLE, XML_DIRPATH)
elif COMMAND == 'rebuild_db_indexes':
admin.rebuild_db_indexes(DATABASE, TABLE)
elif COMMAND == 'optimize_db':
admin.optimize_db(CONTEXT, DATABASE, TABLE)
elif COMMAND == 'refresh_harvested_records':
admin.refresh_harvested_records(CONTEXT, DATABASE, TABLE, URL)
elif COMMAND == 'gen_sitemap':
admin.gen_sitemap(CONTEXT, DATABASE, TABLE, URL, OUTPUT_FILE)
elif COMMAND == 'post_xml':
print(admin.post_xml(CSW_URL, XML, TIMEOUT))
elif COMMAND == 'get_sysprof':
print(admin.get_sysprof())
elif COMMAND == 'validate_xml':
admin.validate_xml(XML, XSD)
elif COMMAND == 'delete_records':
if not FORCE_CONFIRM:
if input('This will delete all records! Continue? [Y/n] ') == 'Y':
FORCE_CONFIRM = True
print('ERROR: -u is a required argument')
sys.exit(9)
if XML is None:
print('ERROR: -x /path/to/request.xml is a required argument')
sys.exit(10)
elif COMMAND == 'validate_xml':
if XML is None:
print('ERROR: -x /path/to/file.xml is a required argument')
sys.exit(11)
if XSD is None:
print('ERROR: -s /path/to/file.xsd is a required argument')
sys.exit(12)
if COMMAND == 'setup_db':
try:
admin.setup_db(DATABASE, TABLE, HOME)
except Exception as err:
print(err)
print('ERROR: DB creation error. Database tables already exist')
print('Delete tables or database to reinitialize')
elif COMMAND == 'load_records':
admin.load_records(CONTEXT, DATABASE, TABLE, XML_DIRPATH, RECURSIVE, FORCE_CONFIRM)
elif COMMAND == 'export_records':
admin.export_records(CONTEXT, DATABASE, TABLE, XML_DIRPATH)
elif COMMAND == 'rebuild_db_indexes':
admin.rebuild_db_indexes(DATABASE, TABLE)
elif COMMAND == 'optimize_db':
admin.optimize_db(CONTEXT, DATABASE, TABLE)
elif COMMAND == 'refresh_harvested_records':
admin.refresh_harvested_records(CONTEXT, DATABASE, TABLE, URL)
elif COMMAND == 'gen_sitemap':
admin.gen_sitemap(CONTEXT, DATABASE, TABLE, URL, OUTPUT_FILE)
print('ERROR: DB creation error. Database tables already exist')
print('Delete tables or database to reinitialize')
elif COMMAND == 'load_records':
admin.load_records(CONTEXT, DATABASE, TABLE, XML_DIRPATH, RECURSIVE, FORCE_CONFIRM)
elif COMMAND == 'export_records':
admin.export_records(CONTEXT, DATABASE, TABLE, XML_DIRPATH)
elif COMMAND == 'rebuild_db_indexes':
admin.rebuild_db_indexes(DATABASE, TABLE)
elif COMMAND == 'optimize_db':
admin.optimize_db(CONTEXT, DATABASE, TABLE)
elif COMMAND == 'refresh_harvested_records':
admin.refresh_harvested_records(CONTEXT, DATABASE, TABLE, URL)
elif COMMAND == 'gen_sitemap':
admin.gen_sitemap(CONTEXT, DATABASE, TABLE, URL, OUTPUT_FILE)
elif COMMAND == 'post_xml':
print(admin.post_xml(CSW_URL, XML, TIMEOUT))
elif COMMAND == 'get_sysprof':
print(admin.get_sysprof())
elif COMMAND == 'validate_xml':
admin.validate_xml(XML, XSD)
elif COMMAND == 'delete_records':
if not FORCE_CONFIRM:
if input('This will delete all records! Continue? [Y/n] ') == 'Y':
FORCE_CONFIRM = True
if FORCE_CONFIRM:
admin.delete_records(CONTEXT, DATABASE, TABLE)
print('Done')
except Exception as err:
print(err)
print('ERROR: DB creation error. Database tables already exist')
print('Delete tables or database to reinitialize')
elif COMMAND == 'load_records':
admin.load_records(CONTEXT, DATABASE, TABLE, XML_DIRPATH, RECURSIVE, FORCE_CONFIRM)
elif COMMAND == 'export_records':
admin.export_records(CONTEXT, DATABASE, TABLE, XML_DIRPATH)
elif COMMAND == 'rebuild_db_indexes':
admin.rebuild_db_indexes(DATABASE, TABLE)
elif COMMAND == 'optimize_db':
admin.optimize_db(CONTEXT, DATABASE, TABLE)
elif COMMAND == 'refresh_harvested_records':
admin.refresh_harvested_records(CONTEXT, DATABASE, TABLE, URL)
elif COMMAND == 'gen_sitemap':
admin.gen_sitemap(CONTEXT, DATABASE, TABLE, URL, OUTPUT_FILE)
elif COMMAND == 'post_xml':
print(admin.post_xml(CSW_URL, XML, TIMEOUT))
elif COMMAND == 'get_sysprof':
print(admin.get_sysprof())
elif COMMAND == 'validate_xml':
admin.validate_xml(XML, XSD)
elif COMMAND == 'delete_records':
if not FORCE_CONFIRM:
if input('This will delete all records! Continue? [Y/n] ') == 'Y':
FORCE_CONFIRM = True
if FORCE_CONFIRM:
admin.delete_records(CONTEXT, DATABASE, TABLE)
print('Done')
database, table = self._get_db_settings()
if args.db_command == "create":
home = self.config.get('server', 'home')
admin.setup_db(database, table, home)
elif args.db_command == "optimize":
admin.optimize_db(self.context, database, table)
elif args.db_command == "rebuild":
admin.rebuild_db_indexes(database, table)
elif args.db_command == "clean":
force = args.accept_changes
if not force:
msg = "This will delete all records! Continue [Y/n] "
if raw_input(msg) == 'Y':
force = True
if force:
admin.delete_records(self.context, database, table)
if COMMAND == 'setup_db':
try:
admin.setup_db(DATABASE, TABLE, HOME)
except Exception as err:
print(err)
print('ERROR: DB creation error. Database tables already exist')
print('Delete tables or database to reinitialize')
elif COMMAND == 'load_records':
admin.load_records(CONTEXT, DATABASE, TABLE, XML_DIRPATH, RECURSIVE, FORCE_CONFIRM)
elif COMMAND == 'export_records':
admin.export_records(CONTEXT, DATABASE, TABLE, XML_DIRPATH)
elif COMMAND == 'rebuild_db_indexes':
admin.rebuild_db_indexes(DATABASE, TABLE)
elif COMMAND == 'optimize_db':
admin.optimize_db(CONTEXT, DATABASE, TABLE)
elif COMMAND == 'refresh_harvested_records':
admin.refresh_harvested_records(CONTEXT, DATABASE, TABLE, URL)
elif COMMAND == 'gen_sitemap':
admin.gen_sitemap(CONTEXT, DATABASE, TABLE, URL, OUTPUT_FILE)
elif COMMAND == 'post_xml':
print(admin.post_xml(CSW_URL, XML, TIMEOUT))
elif COMMAND == 'get_sysprof':
print(admin.get_sysprof())
elif COMMAND == 'validate_xml':
admin.validate_xml(XML, XSD)
elif COMMAND == 'delete_records':
if not FORCE_CONFIRM:
if input('This will delete all records! Continue? [Y/n] ') == 'Y':
FORCE_CONFIRM = True
if FORCE_CONFIRM:
admin.delete_records(CONTEXT, DATABASE, TABLE)
try:
admin.setup_db(DATABASE, TABLE, HOME)
except Exception as err:
print(err)
print('ERROR: DB creation error. Database tables already exist')
print('Delete tables or database to reinitialize')
elif COMMAND == 'load_records':
admin.load_records(CONTEXT, DATABASE, TABLE, XML_DIRPATH, RECURSIVE, FORCE_CONFIRM)
elif COMMAND == 'export_records':
admin.export_records(CONTEXT, DATABASE, TABLE, XML_DIRPATH)
elif COMMAND == 'rebuild_db_indexes':
admin.rebuild_db_indexes(DATABASE, TABLE)
elif COMMAND == 'optimize_db':
admin.optimize_db(CONTEXT, DATABASE, TABLE)
elif COMMAND == 'refresh_harvested_records':
admin.refresh_harvested_records(CONTEXT, DATABASE, TABLE, URL)
elif COMMAND == 'gen_sitemap':
admin.gen_sitemap(CONTEXT, DATABASE, TABLE, URL, OUTPUT_FILE)
elif COMMAND == 'post_xml':
print(admin.post_xml(CSW_URL, XML, TIMEOUT))
elif COMMAND == 'get_sysprof':
print(admin.get_sysprof())
elif COMMAND == 'validate_xml':
admin.validate_xml(XML, XSD)
elif COMMAND == 'delete_records':
if not FORCE_CONFIRM:
if input('This will delete all records! Continue? [Y/n] ') == 'Y':
FORCE_CONFIRM = True
if FORCE_CONFIRM:
admin.delete_records(CONTEXT, DATABASE, TABLE)
print('Done')