edg-l/ddnet
1
0
Fork 0
mirror of https://github.com/ddnet/ddnet.git synced 2024-11-09 17:48:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add BindNull to SQL api

Browse source 
Comes in handy in my downstream project
This commit is contained in:
ChillerDragon 2024-09-15 09:14:00 +08:00
parent 5a4d8e26e6
commit 7c2f058c40
3 changed files with 26 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
src/engine/server/databases/connection.h
View file

@ -61,6 +61,7 @@ public:
virtual void BindInt(int Idx, int Value) = 0; virtual void BindInt(int Idx, int Value) = 0;
virtual void BindInt64(int Idx, int64_t Value) = 0; virtual void BindInt64(int Idx, int64_t Value) = 0;
virtual void BindFloat(int Idx, float Value) = 0; virtual void BindFloat(int Idx, float Value) = 0;
virtual void BindNull(int Idx) = 0;
// Print expanded sql statement // Print expanded sql statement
virtual void Print() = 0; virtual void Print() = 0;

17
src/engine/server/databases/mysql.cpp
View file

@ -89,6 +89,7 @@ public:
void BindInt(int Idx, int Value) override; void BindInt(int Idx, int Value) override;
void BindInt64(int Idx, int64_t Value) override; void BindInt64(int Idx, int64_t Value) override;
void BindFloat(int Idx, float Value) override; void BindFloat(int Idx, float Value) override;
void BindNull(int Idx) override;
void Print() override {} void Print() override {}
bool Step(bool *pEnd, char *pError, int ErrorSize) override; bool Step(bool *pEnd, char *pError, int ErrorSize) override;
@ -421,6 +422,22 @@ void CMysqlConnection::BindFloat(int Idx, float Value)
pParam->error = nullptr; pParam->error = nullptr;
} }
void CMysqlConnection::BindNull(int Idx)
{
m_NewQuery = true;
Idx -= 1;
dbg_assert(0 <= Idx && Idx < (int)m_vStmtParameters.size(), "index out of bounds");
MYSQL_BIND *pParam = &m_vStmtParameters[Idx];
pParam->buffer_type = MYSQL_TYPE_NULL;
pParam->buffer = nullptr;
pParam->buffer_length = 0;
pParam->length = nullptr;
pParam->is_null = nullptr;
pParam->is_unsigned = false;
pParam->error = nullptr;
}
bool CMysqlConnection::Step(bool *pEnd, char *pError, int ErrorSize) bool CMysqlConnection::Step(bool *pEnd, char *pError, int ErrorSize)
{ {
if(m_NewQuery) if(m_NewQuery)

8
src/engine/server/databases/sqlite.cpp
View file

@ -37,6 +37,7 @@ public:
void BindInt(int Idx, int Value) override; void BindInt(int Idx, int Value) override;
void BindInt64(int Idx, int64_t Value) override; void BindInt64(int Idx, int64_t Value) override;
void BindFloat(int Idx, float Value) override; void BindFloat(int Idx, float Value) override;
void BindNull(int Idx) override;
void Print() override; void Print() override;
bool Step(bool *pEnd, char *pError, int ErrorSize) override; bool Step(bool *pEnd, char *pError, int ErrorSize) override;
@ -241,6 +242,13 @@ void CSqliteConnection::BindFloat(int Idx, float Value)
m_Done = false; m_Done = false;
} }
void CSqliteConnection::BindNull(int Idx)
{
int Result = sqlite3_bind_null(m_pStmt, Idx);
AssertNoError(Result);
m_Done = false;
}
// Keep support for SQLite < 3.14 on older Linux distributions. MinGW does not // Keep support for SQLite < 3.14 on older Linux distributions. MinGW does not
// support __attribute__((weak)): https://sourceware.org/bugzilla/show_bug.cgi?id=9687 // support __attribute__((weak)): https://sourceware.org/bugzilla/show_bug.cgi?id=9687
#if defined(__GNUC__) && !defined(__MINGW32__) #if defined(__GNUC__) && !defined(__MINGW32__)