如何防止打开文件使用MySQL连接器

Question

它显示的错误代码在C++中太多：Can't create socket(24)，经过我的调查，我知道那是达到open_files_limit，我检查在MySQL中show global variables like 'open%'; 和值是5000000，所以我的代码必须它有一些问题。

这里是我的简单的代码：

class DB { 
    public: 
    double query1(); 
    double query2(); 
    double query3(); 
}; 

main() { 
    DB handler; 
    for(int i=0;i<100000;i++) { 
     handler.query1(); 
     handler.query2(); 
     handler.query3(); 
    } 
} 

我写了一个类处理3的查询，并在循环中运行它，我怎么能阻止打开文件限制问题，在这个类

这里的查询代码：

double query1(string pair) { 
    double get_prob; 
    try { 
     /* Create a connection */ 
     driver = get_driver_instance(); 
     con = driver->connect("localhost", "root", "nlpgroup"); 
     /* Connect to the MySQL test database */ 
     con->setSchema("em_im"); 
     stmt = con->createStatement(); 
     stringstream stmvar; 
     stmvar << "select prob from em where pair='" << pair << "'"; 
     string stmvarstr = stmvar.str(); 
     cout << stmvarstr << endl; 
     res = stmt->executeQuery(stmvarstr); // replace with your statement 
     while (res->next()) { 
      get_prob = atof(res->getString(1).c_str()); 
     } 
     res->close(); 
     stmt->close(); 
     con->close(); 

     delete res; 
     delete stmt; 
     delete con; 
    } 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; 
    } 
    return get_prob; 
} 

Answer 1

show global variables like 'open%';在MySQL

除了MySQL，你的操作系统也可能会施加限制。对于linux，看看/etc/security/limits.conf，在Windows上，this答案可能会帮助你。

但是，如果您需要一个又一个的连接，那么打开一次并保持打开状态直到程序终止是一个更好的选择。这还会为您带来更好的性能 - 而且您可以使用预先准备好的语句来提高性能。我说这个已经在下面的例子...的std::unique_ptr

class DB 
{ 
    std::unique_ptr <sql::Connection> con; 
    std::unique_ptr <sql::PreparedStatement> stmt; 
public: 
    DB(); 
    double query1(std::string const& pair); 
}; 

DB::DB() 
    : con(get_driver_instance()->connect("localhost", "root", "nlpgroup")) 
{ 
    con->setSchema("em_im"); 
    // you might prefer a prepared statement 
    stmt.reset(con->prepareStatement("SELECT prob FROM em WHERE pair = ?")); 
} 

double DB::query1(std::string const& pair) 
{ 
    double get_prob = 0.0; 
    try 
    { 
     stmt->setString(1, pair); 
     std::unique_ptr <sql::ResultSet> res(stmt->execute()); 
     while (res->next()) 
     { 
      get_prob = atof(res->getString(1).c_str()); 
     } 
    } 
    catch(sql::SQLException& e) 
    { 
     /* ... */ 
    } 
    return get_prob; 
} 

用法保证所有对象均即使在例外的情况下，正确删除 - 这，顺便说一下，你的代码没有。我没有明确地打电话给close - 无论如何它都会在对象的析构函数中调用，所以这很好。

请注意，构造函数现在也可以抛出一个异常，所以您还需要在主函数中尝试catch。根据您的需要，您可以在查询功能中省略try-catch。然而，这改变了行为：即使在两者之间出现故障的情况下，保留所有查询的执行结果，而删除它会导致中止循环。