BAD_2019_PojProg/postgres_cpp/postgres_connector.cpp
2019-04-19 16:53:20 +02:00

57 lines
1.7 KiB
C++

#include <iostream>
#include <iomanip>
#include <pqxx/pqxx>
#include <sstream>
#include <string>
#define HOST "127.0.0.1"
#define DATABASE "fabryka_sprzetu_it"
#define SQL "SELECT * FROM PC;"
#define COL_W 15 //if some table contetnts have too much characters/numbers in it, change this value.
using namespace std;
using namespace pqxx;
int main() {
//welcome message & prompt
cout << "Welcome to MySQL connector. \nYou are trying to connect to host: " << HOST << "\nType your credentials to connect:\n";
string username, password;
cout << "User: ";
cin >> username;
cout << "Password: ";
cin >> password;
//prases the text to match the connection typedef input arg
stringstream stream;
stream << "dbname = " << DATABASE << " user = " << username << " password = " << password << " \
hostaddr = " << HOST << " port = 5432";
try {
connection C(stream.str());
if (!C.is_open()) return 1; //closes the program if there's an issue with connection
nontransaction N(C);
result R(N.exec(SQL));
//print result of last used query
cout << SQL << endl;
//print column names
for(int i=0; i<(int)R[0].size(); i++)
cout << right << setw(COL_W) << R.column_name(i);
cout << endl;
//print table contents
for (result::const_iterator r = R.begin(); r!=R.end(); r++){
for(int i=0; i<(int)R[0].size(); i++)
cout << right << setw(COL_W) << r[i].as<string>();
cout << endl;
}
//end connection
C.disconnect();
} catch (const exception &e) {
cerr << e.what() << std::endl;
return 1;
}
}