udo/uce
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Keep MySQL connect available to wasm units

Browse Source
This commit is contained in:
root 2026-07-13 06:24:59 +00:00
parent b1dfe6c807
commit 7281302287
2 changed files with 24 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
src/lib/mysql-connector.cpp
View File

@ -15,31 +15,6 @@ static void mysql_register_request_connection(MySQL* db)
connections.push_back(db);
}
MySQL* mysql_connect(String host, String username, String password)
{
if(context)
{
for(void* raw : context->resources.mysql_connections)
{
MySQL* db = (MySQL*)raw;
if(db && db->request_pooled && db->connection && db->request_host == host && db->request_username == username && db->request_password == password)
{
db->request_leases++;
return(db);
}
}
}
MySQL* db = new MySQL();
db->request_cleanup_delete = true;
db->request_pooled = context != 0;
db->request_leases = 1;
db->request_host = host;
db->request_username = username;
db->request_password = password;
db->connect(host, username, password);
return(db);
}
bool MySQL::connect(String host, String username, String password)
{
// Register regardless of outcome: tracking is about the wrapper's

25
src/lib/mysql-connector.h
View File

@ -44,7 +44,30 @@ struct MySQL {
};
MySQL* mysql_connect(String host = "localhost", String username = "root", String password = "");
inline MySQL* mysql_connect(String host = "localhost", String username = "root", String password = "")
{
if(context)
{
for(void* raw : context->resources.mysql_connections)
{
MySQL* db = (MySQL*)raw;
if(db && db->request_pooled && db->connection && db->request_host == host && db->request_username == username && db->request_password == password)
{
db->request_leases++;
return(db);
}
}
}
MySQL* db = new MySQL();
db->request_cleanup_delete = true;
db->request_pooled = context != 0;
db->request_leases = 1;
db->request_host = host;
db->request_username = username;
db->request_password = password;
db->connect(host, username, password);
return(db);
}
inline void mysql_disconnect(MySQL* m)
{