Changeset 59061f6 in network-game for server/DataAccess.cpp

Timestamp:

Nov 27, 2012, 7:03:33 PM (12 years ago)

Author:

dportnoy <dmp1488@…>

Branches:

master

Children:

371ce29

Parents:

36082e8

Message:

Added new data access methods to save and retrieve player data

File:

• server/DataAccess.cpp (modified) (3 diffs)

server/DataAccess.cpp

@@ -2 +2 @@
 
 #include <iostream>
-
-#include <mysql/mysql.h>
+#include <sstream>
 
 using namespace std;
@@ -9 +8 @@
 DataAccess::DataAccess()
 {
+   mysql_init(&mysql);
+   connection = mysql_real_connect(&mysql, "localhost", "pythonAdmin", "pyMaster09*", "pythondb", 0, 0, 0);
+
+   if (connection == NULL) {
+      cout << mysql_error(&mysql) << endl;
+   }else
+      cout << "Connection successful" << endl;
 }
 
 DataAccess::~DataAccess()
 {
+   mysql_close(connection);
+   mysql_close(&mysql);
 }
 
-int DataAccess::dbtest()
+int DataAccess::insertPlayer(string username, string password)
 {
-   MYSQL *connection, mysql;
+   ostringstream oss;
+
+   oss << "'" << username << "', '" << password << "'";
+
+   return insert("users", "name, password", oss.str());
+}
+
+Player *DataAccess::getPlayer(string username)
+{
    MYSQL_RES *result;
    MYSQL_ROW row;
-   int query_state;
+   Player *p;
+   ostringstream oss;
 
-   mysql_init(&mysql);
+   oss << "name='" << username << "'";
 
-   connection = mysql_real_connect(&mysql,"localhost","pythonAdmin","pyMaster09*","pythondb",0,0,0);
+   result = select("users", oss.str().c_str());
 
-   if (connection == NULL) {
-      cout << mysql_error(&mysql) << endl;
-      return 1;
-   }else
-      cout << "Connection successful" << endl;
+   if (result == NULL) {
+      cout << mysql_error(connection) << endl;
+      return NULL;
+   }
 
-   query_state = mysql_query(connection, "SELECT * FROM users");
+   if ( ( row = mysql_fetch_row(result)) != NULL )
+      p = new Player(string(row[1]), string(row[2]));
+   else
+      p = NULL;
 
-   if (query_state !=0) {
+   mysql_free_result(result);
+
+   return p;
+}
+
+int DataAccess::printPlayers()
+{
+   MYSQL_RES *result;
+   MYSQL_ROW row;
+   ostringstream oss;
+
+   result = select("users", "");
+
+   if (result == NULL) {
       cout << mysql_error(connection) << endl;
       return 1;
    }
-
-   result = mysql_store_result(connection);
 
    while ( ( row = mysql_fetch_row(result)) != NULL ) {
@@ -46 +76 @@
 
    mysql_free_result(result);
-   mysql_close(connection);
-
-   cout << "Test finished" << endl;
 
    return 0;
 }
+
+int DataAccess::insert(string table, string rows, string values)
+{
+   int query_state;
+   ostringstream oss;
+
+   oss << "INSERT into " << table << " (" << rows << ") VALUES (" << values << ")";
+   cout << "query: " << oss.str() << endl;
+
+   query_state = mysql_query(connection, oss.str().c_str());
+
+   if (query_state != 0) {
+      cout << mysql_error(connection) << endl;
+      return 1;
+   }
+
+   return 0;
+}
+
+MYSQL_RES *DataAccess::select(string table, string filter)
+{
+   MYSQL_RES *result;
+   int query_state;
+   ostringstream oss;
+
+   oss << "SELECT * FROM " << table;
+   if (!filter.empty())
+      oss << " WHERE " << filter;
+
+   query_state = mysql_query(connection, oss.str().c_str());
+
+   if (query_state != 0) {
+      cout << mysql_error(connection) << endl;
+      return NULL;
+   }
+
+   return mysql_store_result(connection);
+}