20
20
#include " expression/function_expression.h"
21
21
#include " expression/operator_expression.h"
22
22
#include " expression/star_expression.h"
23
- #include " expression/tuple_value_expression.h"
24
23
#include " expression/subquery_expression.h"
24
+ #include " expression/tuple_value_expression.h"
25
25
#include " parser/pg_list.h"
26
26
#include " parser/pg_query.h"
27
27
#include " parser/pg_trigger.h"
@@ -286,10 +286,12 @@ expression::AbstractExpression *PostgresParser::ColumnRefTransform(
286
286
->val .str ));
287
287
} else {
288
288
result = new expression::TupleValueExpression (
289
- std::string ((reinterpret_cast <value *>(
290
- fields->head ->next ->data .ptr_value ))->val .str ),
291
- std::string ((reinterpret_cast <value *>(
292
- fields->head ->data .ptr_value ))->val .str ));
289
+ std::string (
290
+ (reinterpret_cast <value *>(fields->head ->next ->data .ptr_value ))
291
+ ->val .str ),
292
+ std::string (
293
+ (reinterpret_cast <value *>(fields->head ->data .ptr_value ))
294
+ ->val .str ));
293
295
}
294
296
break ;
295
297
}
@@ -659,7 +661,7 @@ expression::AbstractExpression *PostgresParser::ExprTransform(Node *node) {
659
661
break ;
660
662
}
661
663
case T_SubLink: {
662
- expr = SubqueryExprTransform (reinterpret_cast <SubLink*>(node));
664
+ expr = SubqueryExprTransform (reinterpret_cast <SubLink *>(node));
663
665
break ;
664
666
}
665
667
case T_NullTest: {
@@ -736,24 +738,28 @@ expression::AbstractExpression *PostgresParser::AExprTransform(A_Expr *root) {
736
738
return result;
737
739
}
738
740
739
- expression::AbstractExpression* PostgresParser::SubqueryExprTransform (SubLink *node) {
741
+ expression::AbstractExpression *PostgresParser::SubqueryExprTransform (
742
+ SubLink *node) {
740
743
if (node == nullptr ) {
741
744
return nullptr ;
742
745
}
743
746
744
- expression::AbstractExpression* expr = nullptr ;
745
- auto select_stmt = SelectTransform (reinterpret_cast <SelectStmt*>(node->subselect ));
747
+ expression::AbstractExpression *expr = nullptr ;
748
+ auto select_stmt =
749
+ SelectTransform (reinterpret_cast <SelectStmt *>(node->subselect ));
746
750
auto subquery_expr = new expression::SubqueryExpression ();
747
- subquery_expr->SetSubSelect (reinterpret_cast <SelectStatement*>(select_stmt));
751
+ subquery_expr->SetSubSelect (reinterpret_cast <SelectStatement *>(select_stmt));
748
752
switch (node->subLinkType ) {
749
753
case ANY_SUBLINK: {
750
754
auto col_expr = ExprTransform (node->testexpr );
751
- expr = new expression::ComparisonExpression (ExpressionType::COMPARE_IN, col_expr, subquery_expr);
755
+ expr = new expression::ComparisonExpression (ExpressionType::COMPARE_IN,
756
+ col_expr, subquery_expr);
752
757
break ;
753
758
}
754
759
case EXISTS_SUBLINK: {
755
- expr = new expression::OperatorExpression (ExpressionType::OPERATOR_EXISTS, type::TypeId::BOOLEAN, subquery_expr,
756
- nullptr );
760
+ expr = new expression::OperatorExpression (ExpressionType::OPERATOR_EXISTS,
761
+ type::TypeId::BOOLEAN,
762
+ subquery_expr, nullptr );
757
763
break ;
758
764
}
759
765
case EXPR_SUBLINK: {
@@ -856,7 +862,8 @@ expression::AbstractExpression *PostgresParser::WhenTransform(Node *root) {
856
862
// This helper function takes in a Postgres ColumnDef object and transforms
857
863
// it into a Peloton ColumnDefinition object. The result of the transformation
858
864
// is also stored into the provided statement
859
- void PostgresParser::ColumnDefTransform (ColumnDef *root, parser::CreateStatement* stmt) {
865
+ void PostgresParser::ColumnDefTransform (ColumnDef *root,
866
+ parser::CreateStatement *stmt) {
860
867
TypeName *type_name = root->typeName ;
861
868
char *name =
862
869
(reinterpret_cast <value *>(type_name->names ->tail ->data .ptr_value )
@@ -905,20 +912,17 @@ void PostgresParser::ColumnDefTransform(ColumnDef *root, parser::CreateStatement
905
912
auto col = new ColumnDefinition (ColumnDefinition::DataType::FOREIGN);
906
913
907
914
col->foreign_key_source .emplace_back (root->colname );
908
- if (constraint->pk_attrs != nullptr )
909
- {
915
+ if (constraint->pk_attrs != nullptr ) {
910
916
auto attr_cell = constraint->pk_attrs ->head ;
911
- value* attr_val =
912
- reinterpret_cast <value*>(attr_cell->data .ptr_value );
917
+ value * attr_val =
918
+ reinterpret_cast <value *>(attr_cell->data .ptr_value );
913
919
col->foreign_key_sink .emplace_back (attr_val->val .str );
914
- }
915
- else
916
- {
920
+ } else {
917
921
// Must specify the referenced columns
918
922
delete result;
919
923
delete col;
920
- throw NotImplementedException (StringUtil::Format (
921
- " Foreign key columns not specified." ));
924
+ throw NotImplementedException (
925
+ StringUtil::Format ( " Foreign key columns not specified." ));
922
926
}
923
927
924
928
// Update Reference Table
@@ -979,7 +983,7 @@ parser::SQLStatement *PostgresParser::CreateTransform(CreateStmt *root) {
979
983
if ((node->type ) == T_ColumnDef) {
980
984
// Transform Regular Column
981
985
try {
982
- ColumnDefTransform (reinterpret_cast <ColumnDef*>(node), result);
986
+ ColumnDefTransform (reinterpret_cast <ColumnDef *>(node), result);
983
987
} catch (NotImplementedException e) {
984
988
delete result;
985
989
throw e;
@@ -1415,7 +1419,7 @@ parser::DropStatement *PostgresParser::DropIndexTransform(DropStmt *root) {
1415
1419
auto cell = root->objects ->head ;
1416
1420
auto list = reinterpret_cast <List *>(cell->data .ptr_value );
1417
1421
result->SetIndexName (
1418
- reinterpret_cast <value *>(list->head ->data .ptr_value )->val .str );
1422
+ reinterpret_cast <value *>(list->head ->data .ptr_value )->val .str );
1419
1423
return result;
1420
1424
}
1421
1425
@@ -1488,8 +1492,9 @@ parser::AnalyzeStatement *PostgresParser::VacuumTransform(VacuumStmt *root) {
1488
1492
return result;
1489
1493
}
1490
1494
1491
- parser::VariableSetStatement *PostgresParser::VariableSetTransform (UNUSED_ATTRIBUTE VariableSetStmt* root) {
1492
- VariableSetStatement* res = new VariableSetStatement ();
1495
+ parser::VariableSetStatement *PostgresParser::VariableSetTransform (
1496
+ UNUSED_ATTRIBUTE VariableSetStmt *root) {
1497
+ VariableSetStatement *res = new VariableSetStatement ();
1493
1498
return res;
1494
1499
}
1495
1500
@@ -1795,7 +1800,7 @@ parser::SQLStatement *PostgresParser::NodeTransform(Node *stmt) {
1795
1800
result = VacuumTransform ((VacuumStmt *)stmt);
1796
1801
break ;
1797
1802
case T_VariableSetStmt:
1798
- result = VariableSetTransform ((VariableSetStmt*)stmt);
1803
+ result = VariableSetTransform ((VariableSetStmt *)stmt);
1799
1804
break ;
1800
1805
case T_ExplainStmt:
1801
1806
result = ExplainTransform (reinterpret_cast <ExplainStmt *>(stmt));
@@ -1811,7 +1816,7 @@ parser::SQLStatement *PostgresParser::NodeTransform(Node *stmt) {
1811
1816
// This function transfers a list of Postgres statements into
1812
1817
// a Peloton SQLStatementList object. It traverses the parse list
1813
1818
// and call the helper for singles nodes.
1814
- parser::SQLStatementList* PostgresParser::ListTransform (List *root) {
1819
+ parser::SQLStatementList * PostgresParser::ListTransform (List *root) {
1815
1820
if (root == nullptr ) {
1816
1821
return nullptr ;
1817
1822
}
0 commit comments