#include #include #include "mysql_connection.h" #include #include #include #include #include using namespace std; int main(void) { try { sql::Driver *driver; sql::Connection *connection; sql::Statement *statement; sql::PreparedStatement *prepared_statement; sql::ResultSet *result; // Create a connection driver = get_driver_instance(); connection = driver -> connect("unix:///tmp/mysql/socket/mysqld.sock", "coderpad", ""); // Connect to the coderpad database connection -> setSchema("coderpad"); // Select all rows from the employees table. statement = connection->createStatement(); result = statement->executeQuery("SELECT * FROM employees;"); sql::ResultSetMetaData *result_meta = result -> getMetaData(); int columnCount = result_meta -> getColumnCount(); int count = 0; cout << "All rows in the employees table:" << endl; while (result -> next()) { // Access result set by index, 1-indexed for (int i = 1; i <= columnCount; i++) { cout << result -> getString(i) << " | " ; } cout << endl; count++; } cout << "There are " << count << " rows." << endl; // Insert a new row using a prepared statement prepared_statement = connection -> prepareStatement("INSERT INTO employees (first_name, last_name) VALUES (?, ?)"); prepared_statement -> setString(1, "Person " + to_string(count)); prepared_statement -> setString(2, "C++"); prepared_statement -> executeUpdate(); delete prepared_statement; delete connection; } catch (sql::SQLException &e) { cout << "# ERR: SQLException in " << __FILE__; cout << "(" << __FUNCTION__ << ") on line " << __LINE__ << endl; cout << "# ERR: " << e.what(); cout << " (MySQL error code: " << e.getErrorCode(); cout << ", SQLState: " << e.getSQLState() << " )" << endl; } cout << endl; return EXIT_SUCCESS; }