|
6 | 6 |
|
7 | 7 | void sql_unlocked(std::string DeleteName)
|
8 | 8 | {
|
9 |
| - try |
10 |
| - { |
| 9 | + sql::mysql::MySQL_Driver *driver = sql::mysql::get_mysql_driver_instance(); |
| 10 | + sql::Connection *con = driver->connect("tcp://8.130.48.157:3306", "root", "abc.123"); |
| 11 | + con->setSchema("flypen"); |
| 12 | + sql::Statement *stmt = con->createStatement(); |
| 13 | + try{ |
11 | 14 | std::string filename = DeleteName;
|
12 |
| - |
13 |
| - // open MySQL |
14 |
| - sql::mysql::MySQL_Driver *driver = sql::mysql::get_mysql_driver_instance(); |
15 |
| - sql::Connection *con = driver->connect("tcp://8.130.48.157:3306", "root", "abc.123"); |
16 |
| - con->setSchema("flypen"); |
17 |
| - |
18 |
| - sql::Statement *stmt = con->createStatement(); |
19 |
| - |
20 | 15 | std::string DeleteQuery = "DELETE FROM file WHERE filename = " + DeleteName;
|
21 |
| - |
22 | 16 | int rowsDelete = stmt->executeUpdate(DeleteQuery);
|
23 |
| - |
24 |
| - delete stmt; |
25 |
| - delete con; |
26 | 17 | }
|
27 | 18 | catch (sql::SQLException &e)
|
28 | 19 | {
|
29 | 20 | std::cerr << "SQL Exception: in sql_unlocked() function" << e.what() << std::endl;
|
30 | 21 | }
|
| 22 | + delete stmt; |
| 23 | + delete con; |
31 | 24 | }
|
32 | 25 |
|
33 | 26 | // relate to chat
|
@@ -58,11 +51,11 @@ int lockcheck(std::string filename){
|
58 | 51 | if(resultSet->getString("filename")==filename) return 1;
|
59 | 52 |
|
60 | 53 | }
|
61 |
| - std::string changestate ="INSERT INTO file(filename) VALUES (?)"; |
62 |
| - sql::PreparedStatement *changestatement =con->prepareStatement(changestate); |
63 |
| - changestatement->setString(1,filename); |
64 |
| - changestatement->executeUpdate(); |
65 |
| - return 0; |
| 54 | + std::string changestate ="INSERT INTO file(filename) VALUES (?)"; |
| 55 | + sql::PreparedStatement *changestatement =con->prepareStatement(changestate); |
| 56 | + changestatement->setString(1,filename); |
| 57 | + changestatement->executeUpdate(); |
| 58 | + return 0; |
66 | 59 | }
|
67 | 60 | void process(sql::PreparedStatement *readDatament, std::vector<std::string> s, sql::Connection *con)
|
68 | 61 | {
|
|
0 commit comments