f0c1035378
The enitities and containers of the catalog now go into catalog subfolder Models go into model
56 lines
1.7 KiB
C++
56 lines
1.7 KiB
C++
#include "PgTriggerContainer.h"
|
|
#include "Pgsql_Connection.h"
|
|
#include "Pgsql_Col.h"
|
|
#include <algorithm>
|
|
#include <iterator>
|
|
|
|
std::string PgTriggerContainer::getLoadQuery() const
|
|
{
|
|
std::string q =
|
|
"SELECT oid, tgname, tgrelid, tgfoid, tgtype, tgenabled, tgisinternal, tgconstrrelid, \n"
|
|
" tgconstrindid, tgconstraint, tgdeferrable, tginitdeferred, tgnargs, tgattr, \n"
|
|
" tgargs, COALESCE(substring(pg_get_triggerdef(oid), 'WHEN (.*) EXECUTE PROCEDURE'), substring(pg_get_triggerdef(oid), 'WHEN (.*) \\$trigger')) AS whenclause";
|
|
if (minimumVersion(90600)) {
|
|
q += ", tgoldtable, tgnewtable";
|
|
}
|
|
q +=
|
|
" FROM pg_trigger \n"
|
|
" WHERE NOT tgisinternal";
|
|
return q;
|
|
}
|
|
|
|
PgTrigger PgTriggerContainer::loadElem(const Pgsql::Row &row)
|
|
{
|
|
|
|
Pgsql::Col col(row);
|
|
Oid oid = col.nextValue();
|
|
QString name = col.nextValue();
|
|
PgTrigger v(m_catalog, oid, name, InvalidOid);
|
|
col >> v.relid >> v.foid >> v.type >> v.enabled >> v.isinternal >> v.constrrelid
|
|
>> v.constrindid >> v.constraint >> v.deferrable >> v.initdeferred >> v.nargs >> v.attr;
|
|
const unsigned char * args_bytea = reinterpret_cast<const unsigned char *>(col.nextValue().c_str());
|
|
if (args_bytea) {
|
|
size_t to_length;
|
|
unsigned char *result = PQunescapeBytea(args_bytea, &to_length);
|
|
if (result) {
|
|
v.args = QString::fromUtf8(reinterpret_cast<const char*>(result), static_cast<int>(to_length));
|
|
PQfreemem(result);
|
|
}
|
|
}
|
|
col >> v.whenclause;
|
|
if (minimumVersion(90600)) {
|
|
col >> v.oldtable >> v.newtable;
|
|
}
|
|
return v;
|
|
}
|
|
|
|
|
|
std::vector<PgTrigger> PgTriggerContainer::getTriggersForRelation(Oid cls) const
|
|
{
|
|
std::vector<PgTrigger> result;
|
|
for (auto e : m_container)
|
|
if (e.relid == cls)
|
|
result.push_back(e);
|
|
|
|
return result;
|
|
}
|