Skip to content

Commit

Permalink
EDA_QUERY_2 patos
Browse files Browse the repository at this point in the history
  • Loading branch information
@jortilles
jortilles committed Aug 14, 2024
1 parent 9cf5c6a commit 880cf8d
Show file tree
Hide file tree
Showing 4 changed files with 246 additions and 5 deletions.
3 changes: 1 addition & 2 deletions eda/eda_api/lib/services/query-builder/qb-systems/bigquery-builder.service.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -80,8 +80,7 @@ export class BigQueryBuilderService extends QueryBuilderService {
for (const key in alias) {
myQuery = myQuery.split(key).join(`\`${alias[key]}\``);
}


}

return myQuery;
}
Expand Down
78 changes: 77 additions & 1 deletion eda/eda_api/lib/services/query-builder/qb-systems/oracle-builder.service.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,15 @@ export class OracleBuilderService extends QueryBuilderService {
}


const joinString = this.getJoins(joinTree, dest, tables, joinType, valueListJoins);
let joinString: any[];
let alias: any;
if (this.queryTODO.joined) {
const responseJoins = this.setJoins(joinTree, joinType, valueListJoins);
joinString = responseJoins.joinString;
alias = responseJoins.aliasTables;
} else {
joinString = this.getJoins(joinTree, dest, tables, joinType, valueListJoins );
}


joinString.forEach(x => {
Expand Down Expand Up @@ -53,6 +61,14 @@ export class OracleBuilderService extends QueryBuilderService {
myQuery = `${myQuery}\norder by ${order_columns_string}`;
}

if (alias) {
console.log(alias);
for (const key in alias) {
myQuery = myQuery.split(key).join(`"${alias[key]}"`);
}
}


if (limit) myQuery = `SELECT * FROM (${myQuery})\n WHERE ROWNUM <= ${limit}`;
return myQuery;
}
Expand Down Expand Up @@ -165,6 +181,66 @@ export class OracleBuilderService extends QueryBuilderService {
return joinString;
}



public setJoins(joinTree: any[], joinType: string, valueListJoins: string[]) {

// Inicialización de variables
const joinExists = new Set();
const aliasTables = {};
const joinString = [];
const targetTableJoin = [];

for (const join of joinTree) {
// División de las partes de la join
const [sourceTable, sourceColumn] = join[0].split('.');
const [targetTable, targetColumn] = join[1].split('.');

// Construcción de las partes de la join
const sourceJoin = ` "${sourceTable}"."${sourceColumn}"`;
let targetJoin = ` "${targetTable}"."${targetColumn}"`;

// Si la join no existe ya, se añade
if (!joinExists.has(`${sourceJoin}=${targetJoin}`)) {
joinExists.add(`${sourceJoin}=${targetJoin}`);

// Construcción de los alias
const alias = `"${targetTable}.${targetColumn}"`;
aliasTables[alias] = targetTable;

let aliasTargetTable: string;
if (targetTableJoin.includes(targetTable)) {
aliasTargetTable = `${targetTable}${targetTableJoin.indexOf(targetTable)}`;
aliasTables[alias] = aliasTargetTable;
}

let joinStr: string;

joinType = valueListJoins.includes(targetTable) ? 'LEFT' : joinType;

if (aliasTargetTable) {
targetJoin = `"${aliasTargetTable}"."${targetColumn}"`;
joinStr = `${joinType} JOIN " ${targetTable}" "${aliasTargetTable}" ON ${sourceJoin} = ${targetJoin}`;
} else {
joinStr = `${joinType} JOIN " ${targetTable}" ON ${sourceJoin} = ${targetJoin}`;
}

// Si la join no se ha incluido ya, se añade al array
if (!joinString.includes(joinStr)) {
targetTableJoin.push(aliasTargetTable || targetTable);
joinString.push(joinStr);
}
}
}

return {
joinString,
aliasTables
};
}



public getSeparedColumns(origin: string, dest: string[]) {
const columns = [];
const grouping = [];
Expand Down
85 changes: 84 additions & 1 deletion eda/eda_api/lib/services/query-builder/qb-systems/snowflake-builder.service.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -25,8 +25,19 @@ export class SnowFlakeBuilderService extends QueryBuilderService {
myQuery = `SELECT DISTINCT ${columns.join(', ')} \nFROM ${o}`;
}


// JOINS
const joinString = this.getJoins(joinTree, dest, tables, joinType,valueListJoins, SCHEMA);
let joinString: any[];
let alias: any;
if (this.queryTODO.joined) {
const responseJoins = this.setJoins(joinTree, joinType, SCHEMA, valueListJoins);
joinString = responseJoins.joinString;
alias = responseJoins.aliasTables;
} else {
joinString = this.getJoins(joinTree, dest, tables, joinType, valueListJoins, SCHEMA);
}



joinString.forEach(x => {
myQuery = myQuery + '\n' + x;
Expand Down Expand Up @@ -60,6 +71,17 @@ export class SnowFlakeBuilderService extends QueryBuilderService {
if (order_columns_string.length > 0) {
myQuery = `${myQuery}\norder by ${order_columns_string}`;
}


if (limit) myQuery += `\nlimit ${limit}`;

if (alias) {
console.log(alias);
for (const key in alias) {
myQuery = myQuery.split(key).join(`"${alias[key]}"`);
}
}

return myQuery;
}

Expand Down Expand Up @@ -164,6 +186,67 @@ export class SnowFlakeBuilderService extends QueryBuilderService {
return joinString;
}


public setJoins(joinTree: any[], joinType: string, schema: string, valueListJoins: string[]) {
// Si no se especifica un esquema, se utiliza 'public' por defecto
if (!schema || schema === 'null') {
schema = 'public';
}

// Inicialización de variables
const joinExists = new Set();
const aliasTables = {};
const joinString = [];
const targetTableJoin = [];

for (const join of joinTree) {
// División de las partes de la join
const [sourceTable, sourceColumn] = join[0].split('.');
const [targetTable, targetColumn] = join[1].split('.');

// Construcción de las partes de la join
const sourceJoin = `"${schema}"."${sourceTable}"."${sourceColumn}"`;
let targetJoin = `"${schema}"."${targetTable}"."${targetColumn}"`;

// Si la join no existe ya, se añade
if (!joinExists.has(`${sourceJoin}=${targetJoin}`)) {
joinExists.add(`${sourceJoin}=${targetJoin}`);

// Construcción de los alias
const alias = `"${targetTable}.${targetColumn}"`;
aliasTables[alias] = targetTable;

let aliasTargetTable: string;
if (targetTableJoin.includes(targetTable)) {
aliasTargetTable = `${targetTable}${targetTableJoin.indexOf(targetTable)}`;
aliasTables[alias] = aliasTargetTable;
}

let joinStr: string;

joinType = valueListJoins.includes(targetTable) ? 'LEFT' : joinType;

if (aliasTargetTable) {
targetJoin = `"${aliasTargetTable}"."${targetColumn}"`;
joinStr = `${joinType} JOIN "${schema}"."${targetTable}" "${aliasTargetTable}" ON ${sourceJoin} = ${targetJoin}`;
} else {
joinStr = `${joinType} JOIN "${schema}"."${targetTable}" ON ${sourceJoin} = ${targetJoin}`;
}

// Si la join no se ha incluido ya, se añade al array
if (!joinString.includes(joinStr)) {
targetTableJoin.push(aliasTargetTable || targetTable);
joinString.push(joinStr);
}
}
}

return {
joinString,
aliasTables
};
}

public getSeparedColumns(origin: string, dest: string[]) {
const columns = [];
const grouping = [];
Expand Down
85 changes: 84 additions & 1 deletion eda/eda_api/lib/services/query-builder/qb-systems/sqlserver-builder-service.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,16 @@ export class SQLserviceBuilderService extends QueryBuilderService {
}

// JOINS
const joinString = this.getJoins(joinTree, dest, tables, joinType,valueListJoins, SCHEMA);
let joinString: any[];
let alias: any;
if (this.queryTODO.joined) {
const responseJoins = this.setJoins(joinTree, joinType, schema, valueListJoins);
joinString = responseJoins.joinString;
alias = responseJoins.aliasTables;
} else {
joinString = this.getJoins(joinTree, dest, tables, joinType, valueListJoins, schema);
}


joinString.forEach(x => {
myQuery = myQuery + '\n' + x;
Expand Down Expand Up @@ -62,6 +71,17 @@ export class SQLserviceBuilderService extends QueryBuilderService {
if (order_columns_string.length > 0) {
myQuery = `${myQuery}\norder by ${order_columns_string}`;
}


if (alias) {
console.log(alias);
for (const key in alias) {
myQuery = myQuery.split(key).join(`"${alias[key]}"`);
}
}



return myQuery;
}

Expand Down Expand Up @@ -163,6 +183,69 @@ export class SQLserviceBuilderService extends QueryBuilderService {
return joinString;
}



public setJoins(joinTree: any[], joinType: string, schema: string, valueListJoins: string[]) {
// Si no se especifica un esquema, se utiliza 'public' por defecto
if (!schema || schema === 'null') {
schema = 'public';
}

// Inicialización de variables
const joinExists = new Set();
const aliasTables = {};
const joinString = [];
const targetTableJoin = [];

for (const join of joinTree) {
// División de las partes de la join
const [sourceTable, sourceColumn] = join[0].split('.');
const [targetTable, targetColumn] = join[1].split('.');

// Construcción de las partes de la join
const sourceJoin = `"${schema}"."${sourceTable}"."${sourceColumn}"`;
let targetJoin = `"${schema}"."${targetTable}"."${targetColumn}"`;

// Si la join no existe ya, se añade
if (!joinExists.has(`${sourceJoin}=${targetJoin}`)) {
joinExists.add(`${sourceJoin}=${targetJoin}`);

// Construcción de los alias
const alias = `"${targetTable}.${targetColumn}"`;
aliasTables[alias] = targetTable;

let aliasTargetTable: string;
if (targetTableJoin.includes(targetTable)) {
aliasTargetTable = `${targetTable}${targetTableJoin.indexOf(targetTable)}`;
aliasTables[alias] = aliasTargetTable;
}

let joinStr: string;

joinType = valueListJoins.includes(targetTable) ? 'LEFT' : joinType;

if (aliasTargetTable) {
targetJoin = `"${aliasTargetTable}"."${targetColumn}"`;
joinStr = `${joinType} JOIN "${schema}"."${targetTable}" "${aliasTargetTable}" ON ${sourceJoin} = ${targetJoin}`;
} else {
joinStr = `${joinType} JOIN "${schema}"."${targetTable}" ON ${sourceJoin} = ${targetJoin}`;
}

// Si la join no se ha incluido ya, se añade al array
if (!joinString.includes(joinStr)) {
targetTableJoin.push(aliasTargetTable || targetTable);
joinString.push(joinStr);
}
}
}

return {
joinString,
aliasTables
};
}


public getSeparedColumns(origin: string, dest: string[]) {
const columns = [];
const grouping = [];
Expand Down

0 comments on commit 880cf8d

Please sign in to comment.