Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- n_mysql_connect( AMX* amx, cell* params )
- {
- int
- h = -1;
- for(int i = 0; i < MAX_CONNECTIONS; i++)
- if (my[i].mysql == NULL)
- {
- h = i;
- break;
- }
- if (!param_count(5))
- {
- GenerateError(h, "Function: 'mysql_connect' called with incorrect param count", P_ERROR_INCPARAMCNT);
- return -1;
- }
- if (h == -1)
- {
- GenerateError(h, "Max connections (4) reached. Could not connect", P_ERROR_MAXCONN);
- return -1;
- }
- const char
- *host = GetParam(amx, params[1]),
- *user = GetParam(amx, params[2]),
- *pass = GetParam(amx, params[3]),
- *db = GetParam(amx, params[4]);
- if (params[5] == 0 || params[5] == 1)
- my[h].reconnect = (my_bool)params[5];
- my[h].mysql = mysql_init(NULL);
- if (mysql_real_connect(my[h].mysql, host, user, pass, db, 0, NULL, 0))
- {
- mysql_options(my[h].mysql, MYSQL_OPT_RECONNECT, &my[h].reconnect);
- logprintf("MySQL: Connected (%d) to %s @ %s. MySQL version %s.", h, user, mysql_get_host_info(my[h].mysql), mysql_get_server_info(my[h].mysql));
- if (my[h].logging == LOG_ALL)
- Log("Connected (%d) to %s @ %s. MySQL version %s.", h, user, mysql_get_host_info(my[h].mysql), mysql_get_server_info(my[h].mysql));
- my[h].connected = true;
- }
- else
- {
- GenerateError(h, "Failed to connect", mysql_errno(my[h].mysql));
- h = -1;
- }
- delete [] host;
- delete [] user;
- delete [] pass;
- delete [] db;
- return h;
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement