initial commit
This commit is contained in:
commit
7f6c6e6db7
34
mysql_python/mysql_connect.py
Normal file
34
mysql_python/mysql_connect.py
Normal file
@ -0,0 +1,34 @@
|
||||
import mysql.connector
|
||||
import getpass
|
||||
|
||||
HOST="localhost"
|
||||
DATABASE="Fabryka_Sprzetu_IT"
|
||||
SQL=("SELECT * FROM Produkt;")
|
||||
|
||||
|
||||
print("Welcome to MySQL connector. \nYou are trying to connect to host: " + HOST + "\nType your credentials to connect:")
|
||||
|
||||
while(True):
|
||||
print("User: ", end='')
|
||||
user=input()
|
||||
password=getpass.getpass()
|
||||
print()
|
||||
try:
|
||||
sqlDatabase = mysql.connector.connect(host=HOST, user=user, passwd=password, database=DATABASE)
|
||||
break
|
||||
except mysql.connector.Error as e:
|
||||
print(e)
|
||||
if e.errno!=1045:
|
||||
exit()
|
||||
else:
|
||||
print("Try again.\n")
|
||||
|
||||
|
||||
curs=sqlDatabase.cursor()
|
||||
print(SQL)
|
||||
curs.execute(SQL)
|
||||
res=curs.fetchall()
|
||||
|
||||
for r in res:
|
||||
print(r)
|
||||
|
BIN
postres_cpp/a.out
Executable file
BIN
postres_cpp/a.out
Executable file
Binary file not shown.
57
postres_cpp/posgres_connector.cpp
Normal file
57
postres_cpp/posgres_connector.cpp
Normal file
@ -0,0 +1,57 @@
|
||||
#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;
|
||||
}
|
||||
}
|
Loading…
Reference in New Issue
Block a user