@@ -40,12 +40,10 @@ int sql_findexist(std::string receiver){
40
40
sql::PreparedStatement * readdatament = con->prepareStatement (readdata);
41
41
sql::ResultSet *resultSet =readdatament->executeQuery ();
42
42
std::string usernamelist;
43
- if (resultSet->next ()){
44
- usernamelist = resultSet->getString (" username" );
43
+ while (resultSet->next ()){
44
+ if (receiver == resultSet->getString (" username" )) return 1 ;
45
45
}
46
- int pos = usernamelist.find (receiver);
47
- if (pos!=std::string::npos)return 1 ;
48
- else return 0 ;
46
+ return 0 ;
49
47
}
50
48
int lockcheck (std::string filename){
51
49
sql::mysql::MySQL_Driver *driver = sql::mysql::get_mysql_driver_instance ();
@@ -54,20 +52,17 @@ int lockcheck(std::string filename){
54
52
std::string readData =" SELECT filename FROM file" ;
55
53
sql::PreparedStatement *readdatament =con->prepareStatement (readData);
56
54
sql::ResultSet *resultSet =readdatament->executeQuery ();
57
- std::string filenamelist;
58
- if (resultSet->next ()){
59
- filenamelist =resultSet->getString (" filename" );
60
- std::cout<<filenamelist<<std::endl;
55
+
56
+ std::string name;
57
+ while (resultSet->next ()){
58
+ if (resultSet->getString (" filename" )==filename) return 1 ;
59
+
61
60
}
62
- int pos =filenamelist.find (filename);
63
- if (pos!=std::string::npos)return 1 ;
64
- else {
65
61
std::string changestate =" INSERT INTO file(filename) VALUES (?)" ;
66
62
sql::PreparedStatement *changestatement =con->prepareStatement (changestate);
67
63
changestatement->setString (1 ,filename);
68
64
changestatement->executeUpdate ();
69
65
return 0 ;
70
- }
71
66
}
72
67
void process (sql::PreparedStatement *readDatament, std::vector<std::string> s, sql::Connection *con)
73
68
{
0 commit comments