Skip to content

Commit

Permalink
dbcopy: renamed a function and add log output
Browse files Browse the repository at this point in the history
  • Loading branch information
franku authored and pstorz committed Jan 31, 2020
1 parent e3291e0 commit f1a1193
Show file tree
Hide file tree
Showing 3 changed files with 11 additions and 5 deletions.
10 changes: 7 additions & 3 deletions core/src/dird/dbcopy/database_column_descriptions.cc
Expand Up @@ -31,7 +31,7 @@ DatabaseColumnDescriptions::DatabaseColumnDescriptions(BareosDb* db) : db_{db}
{
}

void DatabaseColumnDescriptions::SelectTableDescriptions(
void DatabaseColumnDescriptions::SelectColumnDescriptions(
const std::string& sql_query,
DB_RESULT_HANDLER* ResultHandler)
{
Expand Down Expand Up @@ -72,7 +72,11 @@ DatabaseColumnDescriptionsPostgresql::DatabaseColumnDescriptionsPostgresql(
"table_name = '"};
query += table_name;
query += "'";
SelectTableDescriptions(query, ResultHandler);

std::cout << "Collecting column descriptions for: " << table_name
<< std::endl;

SelectColumnDescriptions(query, ResultHandler);
}

int DatabaseColumnDescriptionsMysql::ResultHandler(void* ctx,
Expand Down Expand Up @@ -103,5 +107,5 @@ DatabaseColumnDescriptionsMysql::DatabaseColumnDescriptionsMysql(
query += " table_schema='";
query += db->get_db_name();
query += "'";
SelectTableDescriptions(query, ResultHandler);
SelectColumnDescriptions(query, ResultHandler);
}
4 changes: 2 additions & 2 deletions core/src/dird/dbcopy/database_column_descriptions.h
Expand Up @@ -47,8 +47,8 @@ class DatabaseColumnDescriptions {
kDataType = 1,
kCharMaxLenght = 2
};
void SelectTableDescriptions(const std::string& sql_query,
DB_RESULT_HANDLER* ResultHandler);
void SelectColumnDescriptions(const std::string& sql_query,
DB_RESULT_HANDLER* ResultHandler);

private:
BareosDb* db_;
Expand Down
2 changes: 2 additions & 0 deletions core/src/dird/dbcopy/database_export_postgresql.cc
Expand Up @@ -37,6 +37,8 @@ DatabaseExportPostgresql::DatabaseExportPostgresql(
if (clear_tables) {
for (const auto& t : table_descriptions_->tables) {
if (t.table_name != "version") {
std::cout << "Deleting contents of table: " << t.table_name
<< std::endl;
std::string query("DELETE ");
query += " FROM ";
query += t.table_name;
Expand Down

0 comments on commit f1a1193

Please sign in to comment.