![]() |
Rosetta
2016.28
|
Database utility functions. More...
#include <basic/database/sql_utils.hh>#include <basic/Tracer.hh>#include <basic/options/keys/inout.OptionKeys.gen.hh>#include <basic/options/keys/out.OptionKeys.gen.hh>#include <basic/options/option.hh>#include <basic/resource_manager/ResourceManager.hh>#include <basic/resource_manager/util.hh>#include <cppdb/errors.h>#include <cppdb/frontend.h>#include <boost/algorithm/string/predicate.hpp>#include <boost/foreach.hpp>#include <boost/iterator/iterator_facade.hpp>#include <boost/lexical_cast.hpp>#include <boost/mpl/bool.hpp>#include <boost/mpl/bool_fwd.hpp>#include <boost/token_functions.hpp>#include <boost/tokenizer.hpp>#include <numeric/random/random.hh>#include <platform/types.hh>#include <utility/excn/Exceptions.hh>#include <utility/exit.hh>#include <utility/file/PathName.hh>#include <utility/options/BooleanOption.hh>#include <utility/options/IntegerOption.hh>#include <utility/options/PathOption.hh>#include <utility/options/ScalarOption_T_.hh>#include <utility/options/StringOption.hh>#include <utility/sql_database/DatabaseSessionManager.fwd.hh>#include <utility/sql_database/DatabaseSessionManager.hh>#include <utility/string_util.hh>#include <utility/vector1.hh>#include <utility/tag/Tag.hh>#include <cstddef>#include <iosfwd>#include <memory>#include <sstream>#include <string>#include <vector>#include <unistd.h>Namespaces | |
| basic | |
| Tags used to tag messeges sent by MPI functions used to decide whether a slave is requesting a new job id or flagging as job as being a bad input. | |
| basic::database | |
Functions | |
| static THREAD_LOCAL basic::Tracer | basic::database::TR ("basic.database.sql_utils") |
| sessionOP | basic::database::get_db_session () |
| Aquire a database session using the command line options transaction type is set to standard. More... | |
| sessionOP | basic::database::get_db_session (std::string const &db_name, std::string const &pq_schema="") |
| Aquire a database session using the command line parameters For postgres databases, the pq_schema acts like a namespace in the database. Transaction type set to standard. More... | |
| sessionOP | basic::database::get_db_session (string const &db_name, TransactionMode::e transaction_mode, Size chunk_size, string const &pq_schema) |
| utility::sql_database::sessionOP | basic::database::get_db_session (utility::sql_database::DatabaseMode::e db_mode, std::string const &db_name, std::string const &pq_schema) |
| sessionOP | basic::database::get_db_session (DatabaseMode::e db_mode, TransactionMode::e transaction_mode, Size chunk_size, string const &db_name, string const &pq_schema) |
| platform::SSize | basic::database::db_partition_from_options (DatabaseMode::e db_mode) |
| @ More... | |
| platform::SSize | basic::database::resolve_db_partition (bool partition_by_mpi_process, platform::SSize manual_partition=-1) |
| Returns partition identifer from mpi rank if in partitioned database mode, or valid manual partition, otherwise -1. More... | |
| statement | basic::database::safely_prepare_statement (string const &statement_string, sessionOP db_session) |
| void | basic::database::safely_write_to_database (statement &statement) |
| result | basic::database::safely_read_from_database (statement &statement) |
| bool | basic::database::table_exists (sessionOP db_session, string const &table_name) |
| void | basic::database::check_statement_sanity (string sql) |
| void | basic::database::insert_or_ignore (string table_name, std::vector< string > column_names, std::vector< string > values, sessionOP db_session) |
| void | basic::database::write_schema_to_database (string schema_str, sessionOP db_session) |
| void | basic::database::set_cache_size (sessionOP db_session, Size cache_size) |
| std::string | basic::database::make_compound_statement (std::string const &table_name, std::vector< std::string > const &column_names, platform::Size const &row_count) |
| utility::sql_database::sessionOP | basic::database::parse_database_connection (utility::tag::TagCOP tag) |
Database utility functions.
1.8.7