mirror of
https://github.com/ultimatepp/ultimatepp.git
synced 2026-07-11 22:03:01 -06:00
*Sql: fixed ugly typo error in *JoinRef
git-svn-id: svn://ultimatepp.org/upp/trunk@4428 f0d560ea-af0d-0410-9eb7-867de7ffcac7
This commit is contained in:
cxl
parent
ab83923243
commit
3908dd189c
1 changed files with 132 additions and 133 deletions
|
|
@ -1,133 +1,132 @@
|
|||
#include "Sql.h"
|
||||
|
||||
NAMESPACE_UPP
|
||||
|
||||
|
||||
struct SchTableInfo {
|
||||
Vector<String> column;
|
||||
Vector<String> ref_table;
|
||||
Vector<String> ref_column;
|
||||
String primary_key;
|
||||
String prefix;
|
||||
};
|
||||
|
||||
ArrayMap<String, SchTableInfo>& sSchTableInfo()
|
||||
{
|
||||
static ArrayMap<String, SchTableInfo> x;
|
||||
return x;
|
||||
}
|
||||
|
||||
void SchDbInfoTable(const char *table)
|
||||
{
|
||||
sSchTableInfo().GetAdd(table);
|
||||
}
|
||||
|
||||
void SchDbInfoColumn(const char *name)
|
||||
{
|
||||
SchTableInfo& f = sSchTableInfo().Top();
|
||||
f.column.Add(ToUpper(f.prefix + name));
|
||||
f.ref_table.Add();
|
||||
f.ref_column.Add();
|
||||
if(IsNull(f.primary_key))
|
||||
f.primary_key = name;
|
||||
}
|
||||
|
||||
void SchDbInfoVar(void (*fn)(), const char *name)
|
||||
{
|
||||
SchTableInfo& f = sSchTableInfo().Top();
|
||||
String h = f.prefix;
|
||||
f.prefix << name << '$';
|
||||
(*fn)();
|
||||
f.prefix = h;
|
||||
}
|
||||
|
||||
void SchDbInfoReferences(const char *table)
|
||||
{
|
||||
sSchTableInfo().Top().ref_table.Top() = table;
|
||||
}
|
||||
|
||||
void SchDbInfoReferences(const char *table, const char *column)
|
||||
{
|
||||
SchDbInfoReferences(table);
|
||||
sSchTableInfo().Top().ref_column.Top() = column;
|
||||
}
|
||||
|
||||
void SchDbInfoPrimaryKey()
|
||||
{
|
||||
SchTableInfo& f = sSchTableInfo().Top();
|
||||
f.primary_key = f.column.Top();
|
||||
}
|
||||
|
||||
void SchDbInfoColumnArray(const char *name, int items)
|
||||
{
|
||||
for(int i = 0; i < items; i++)
|
||||
SchDbInfoColumn(String().Cat() << name << i);
|
||||
}
|
||||
|
||||
const SchTableInfo& GetSchTableInfo(const String& table)
|
||||
{
|
||||
static SchTableInfo sSchTableInfoZero;
|
||||
return sSchTableInfo().Get(~table, sSchTableInfoZero);
|
||||
}
|
||||
|
||||
SqlBool Join(const String& tab1, const String& as1, const String& tab2, const String& as2)
|
||||
{
|
||||
const SchTableInfo& t1 = GetSchTableInfo(tab1);
|
||||
const SchTableInfo& t2 = GetSchTableInfo(tab2);
|
||||
for(int i = 0; i < t1.ref_table.GetCount(); i++)
|
||||
if(t1.ref_table[i] == tab2)
|
||||
return SqlId(t1.column[i]).Of(SqlId(as1)) == SqlId(t2.primary_key).Of(SqlId(as2));
|
||||
for(int i = 0; i < t2.ref_table.GetCount(); i++)
|
||||
if(t2.ref_table[i] == tab1)
|
||||
return SqlId(t2.column[i]).Of(SqlId(as1)) == SqlId(t1.primary_key).Of(SqlId(as2));
|
||||
return SqlBool::False();
|
||||
}
|
||||
|
||||
int sChrf(int c)
|
||||
{
|
||||
return c < 32 ? ' ' : c;
|
||||
}
|
||||
|
||||
StaticMutex sM;
|
||||
|
||||
Vector<String> GetSchColumns(const String& table)
|
||||
{
|
||||
Mutex::Lock __(sM);
|
||||
return Vector<String>(GetSchTableInfo(table).column, 0);
|
||||
}
|
||||
|
||||
SqlBool FindSchJoin(const String& tables)
|
||||
{
|
||||
Mutex::Lock __(sM);
|
||||
static VectorMap<String, SqlBool> cache;
|
||||
if(cache.GetCount() > 20000) // Defend against unlikely dynamic Join permutations
|
||||
cache.Clear();
|
||||
int q = cache.Find(tables);
|
||||
if(q >= 0)
|
||||
return cache[q];
|
||||
Vector<String> s = Split(Filter(tables, sChrf), ',');
|
||||
Vector<String> as;
|
||||
Vector<String> table;
|
||||
for(int i = 0; i < s.GetCount(); i++) {
|
||||
Vector<String> ss = Split(s[i], ' ');
|
||||
if(ss.GetCount()) {
|
||||
table.Add(ss[0]);
|
||||
as.Add(ss.Top());
|
||||
}
|
||||
}
|
||||
if(table.GetCount() >= 2) {
|
||||
String tab1 = table.Top();
|
||||
String as1 = as.Top();
|
||||
for(int i = 0; i < table.GetCount() - 1; i++) {
|
||||
SqlBool b = Join(tab1, as1, table[i], as[i]);
|
||||
if(!b.IsFalse()) {
|
||||
cache.Add(tables, b);
|
||||
return b;
|
||||
}
|
||||
}
|
||||
}
|
||||
NEVER_("Schema join not found");
|
||||
return SqlBool::False();
|
||||
}
|
||||
|
||||
END_UPP_NAMESPACE
|
||||
#include "Sql.h"
|
||||
|
||||
NAMESPACE_UPP
|
||||
|
||||
struct SchTableInfo {
|
||||
Vector<String> column;
|
||||
Vector<String> ref_table;
|
||||
Vector<String> ref_column;
|
||||
String primary_key;
|
||||
String prefix;
|
||||
};
|
||||
|
||||
ArrayMap<String, SchTableInfo>& sSchTableInfo()
|
||||
{
|
||||
static ArrayMap<String, SchTableInfo> x;
|
||||
return x;
|
||||
}
|
||||
|
||||
void SchDbInfoTable(const char *table)
|
||||
{
|
||||
sSchTableInfo().GetAdd(table);
|
||||
}
|
||||
|
||||
void SchDbInfoColumn(const char *name)
|
||||
{
|
||||
SchTableInfo& f = sSchTableInfo().Top();
|
||||
f.column.Add(ToUpper(f.prefix + name));
|
||||
f.ref_table.Add();
|
||||
f.ref_column.Add();
|
||||
if(IsNull(f.primary_key))
|
||||
f.primary_key = name;
|
||||
}
|
||||
|
||||
void SchDbInfoVar(void (*fn)(), const char *name)
|
||||
{
|
||||
SchTableInfo& f = sSchTableInfo().Top();
|
||||
String h = f.prefix;
|
||||
f.prefix << name << '$';
|
||||
(*fn)();
|
||||
f.prefix = h;
|
||||
}
|
||||
|
||||
void SchDbInfoReferences(const char *table)
|
||||
{
|
||||
sSchTableInfo().Top().ref_table.Top() = table;
|
||||
}
|
||||
|
||||
void SchDbInfoReferences(const char *table, const char *column)
|
||||
{
|
||||
SchDbInfoReferences(table);
|
||||
sSchTableInfo().Top().ref_column.Top() = column;
|
||||
}
|
||||
|
||||
void SchDbInfoPrimaryKey()
|
||||
{
|
||||
SchTableInfo& f = sSchTableInfo().Top();
|
||||
f.primary_key = f.column.Top();
|
||||
}
|
||||
|
||||
void SchDbInfoColumnArray(const char *name, int items)
|
||||
{
|
||||
for(int i = 0; i < items; i++)
|
||||
SchDbInfoColumn(String().Cat() << name << i);
|
||||
}
|
||||
|
||||
const SchTableInfo& GetSchTableInfo(const String& table)
|
||||
{
|
||||
static SchTableInfo sSchTableInfoZero;
|
||||
return sSchTableInfo().Get(~table, sSchTableInfoZero);
|
||||
}
|
||||
|
||||
SqlBool Join(const String& tab1, const String& as1, const String& tab2, const String& as2)
|
||||
{
|
||||
const SchTableInfo& t1 = GetSchTableInfo(tab1);
|
||||
const SchTableInfo& t2 = GetSchTableInfo(tab2);
|
||||
for(int i = 0; i < t1.ref_table.GetCount(); i++)
|
||||
if(t1.ref_table[i] == tab2)
|
||||
return SqlId(t1.column[i]).Of(SqlId(as1)) == SqlId(t2.primary_key).Of(SqlId(as2));
|
||||
for(int i = 0; i < t2.ref_table.GetCount(); i++)
|
||||
if(t2.ref_table[i] == tab1)
|
||||
return SqlId(t2.column[i]).Of(SqlId(as2)) == SqlId(t1.primary_key).Of(SqlId(as1));
|
||||
return SqlBool::False();
|
||||
}
|
||||
|
||||
int sChrf(int c)
|
||||
{
|
||||
return c < 32 ? ' ' : c;
|
||||
}
|
||||
|
||||
StaticMutex sM;
|
||||
|
||||
Vector<String> GetSchColumns(const String& table)
|
||||
{
|
||||
Mutex::Lock __(sM);
|
||||
return Vector<String>(GetSchTableInfo(table).column, 0);
|
||||
}
|
||||
|
||||
SqlBool FindSchJoin(const String& tables)
|
||||
{
|
||||
Mutex::Lock __(sM);
|
||||
static VectorMap<String, SqlBool> cache;
|
||||
if(cache.GetCount() > 20000) // Defend against unlikely dynamic Join permutations
|
||||
cache.Clear();
|
||||
int q = cache.Find(tables);
|
||||
if(q >= 0)
|
||||
return cache[q];
|
||||
Vector<String> s = Split(Filter(tables, sChrf), ',');
|
||||
Vector<String> as;
|
||||
Vector<String> table;
|
||||
for(int i = 0; i < s.GetCount(); i++) {
|
||||
Vector<String> ss = Split(s[i], ' ');
|
||||
if(ss.GetCount()) {
|
||||
table.Add(ss[0]);
|
||||
as.Add(ss.Top());
|
||||
}
|
||||
}
|
||||
if(table.GetCount() >= 2) {
|
||||
String tab1 = table.Top();
|
||||
String as1 = as.Top();
|
||||
for(int i = 0; i < table.GetCount() - 1; i++) {
|
||||
SqlBool b = Join(tab1, as1, table[i], as[i]);
|
||||
if(!b.IsFalse()) {
|
||||
cache.Add(tables, b);
|
||||
return b;
|
||||
}
|
||||
}
|
||||
}
|
||||
NEVER_("Schema join not found");
|
||||
return SqlBool::False();
|
||||
}
|
||||
|
||||
END_UPP_NAMESPACE
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue