Method Read

phxsqlclient/phxsqlclientsvrkitconfig.cpp:28–73

}

int PhxSQLClientSvrkitConfig::Read(Comm::CConfig * poConfig, bool isReload) {
    ResetEndPoints();

    std::vector<MySQLEndPoint_t> vecEndPoints;
    bool bFound = false;

    int iSetCount = 0;
    poConfig->ReadItem("Phxsql", "SetCount", 0, iSetCount);
    poConfig->ReadItem("Phxsql", "ConnTimeout", 0, m_iConnTimeout);
    poConfig->ReadItem("Phxsql", "ReadTimeout", 0, m_iReadTimeout);
    for (int i = 0; i < iSetCount; ++i) {
        vecEndPoints.clear();

        char pcSect[16] = { 0 };
        int iServerCount = 0;

        snprintf(pcSect, sizeof(pcSect), "Server%d", i);
        poConfig->ReadItem(pcSect, "ServerCount", 0, iServerCount);

        for (int j = 0; j < iServerCount; ++j) {
            MySQLEndPoint_t tEndPoint;

            char pcKey[16] = { 0 };

            snprintf(pcKey, sizeof(pcKey), "SVR_IP%d", j);
            poConfig->ReadItem(pcSect, pcKey, "", tEndPoint.m_sMySQLIP);

            snprintf(pcKey, sizeof(pcKey), "SVR_PORT%d", j);
            poConfig->ReadItem(pcSect, pcKey, 0, tEndPoint.m_iPort);

            if (tEndPoint.m_sMySQLIP != "" && tEndPoint.m_iPort) {
                vecEndPoints.push_back(tEndPoint);
            }

            if (tEndPoint.m_sMySQLIP == LOGID_BASE::GetInnerIP()) {
                bFound = true;
            }
        }

        if (bFound) {
            SetMySQLEndPoints(vecEndPoints);
            break;
        }
    }
    return phxsql::OK;
}

const std::vector<MySQLEndPoint_t> & PhxSQLClientSvrkitConfig::GetEndPoints() {
    LoadIfModified();