@@ -35,10 +35,12 @@ export class FlinkEntityCollector extends EntityCollector implements FlinkSqlPar
35
35
}
36
36
37
37
exitDatabasePathCreate ( ctx : DatabasePathCreateContext ) {
38
- this . pushEntity ( ctx , EntityContextType . DATABASE_CREATE , {
39
- attrNameList : [ AttrName . comment ] ,
40
- endContextList : [ CreateDatabaseContext . name ] ,
41
- } ) ;
38
+ this . pushEntity ( ctx , EntityContextType . DATABASE_CREATE , [
39
+ {
40
+ attrName : AttrName . comment ,
41
+ endContextList : [ CreateDatabaseContext . name ] ,
42
+ } ,
43
+ ] ) ;
42
44
}
43
45
44
46
exitDatabasePath ( ctx : DatabasePathContext ) {
@@ -51,37 +53,49 @@ export class FlinkEntityCollector extends EntityCollector implements FlinkSqlPar
51
53
ctx ,
52
54
EntityContextType . TABLE ,
53
55
needCollectAttr
54
- ? {
55
- attrNameList : [ AttrName . alias ] ,
56
- endContextList : [ TableReferenceContext . name ] ,
57
- }
56
+ ? [
57
+ {
58
+ attrName : AttrName . alias ,
59
+ endContextList : [ TableReferenceContext . name ] ,
60
+ } ,
61
+ ]
58
62
: undefined
59
63
) ;
60
64
}
61
65
62
66
exitTablePathCreate ( ctx : TablePathCreateContext ) {
63
- this . pushEntity ( ctx , EntityContextType . TABLE_CREATE , {
64
- attrNameList : [ AttrName . comment ] ,
65
- endContextList : [ CreateTableContext . name ] ,
66
- } ) ;
67
+ this . pushEntity ( ctx , EntityContextType . TABLE_CREATE , [
68
+ {
69
+ attrName : AttrName . comment ,
70
+ endContextList : [ CreateTableContext . name ] ,
71
+ } ,
72
+ ] ) ;
67
73
}
68
74
69
75
exitViewPath ( ctx : ViewPathContext ) {
70
76
this . pushEntity ( ctx , EntityContextType . VIEW ) ;
71
77
}
72
78
73
79
exitViewPathCreate ( ctx : ViewPathCreateContext ) {
74
- this . pushEntity ( ctx , EntityContextType . VIEW_CREATE , {
75
- attrNameList : [ AttrName . comment ] ,
76
- endContextList : [ CreateViewContext . name ] ,
77
- } ) ;
80
+ this . pushEntity ( ctx , EntityContextType . VIEW_CREATE , [
81
+ {
82
+ attrName : AttrName . comment ,
83
+ endContextList : [ CreateViewContext . name ] ,
84
+ } ,
85
+ ] ) ;
78
86
}
79
87
80
88
exitColumnNameCreate ( ctx : ColumnNameCreateContext ) {
81
- this . pushEntity ( ctx , EntityContextType . COLUMN_CREATE , {
82
- attrNameList : [ AttrName . comment , AttrName . colType ] ,
83
- endContextList : [ PhysicalColumnDefinitionContext . name ] ,
84
- } ) ;
89
+ this . pushEntity ( ctx , EntityContextType . COLUMN_CREATE , [
90
+ {
91
+ attrName : AttrName . comment ,
92
+ endContextList : [ PhysicalColumnDefinitionContext . name ] ,
93
+ } ,
94
+ {
95
+ attrName : AttrName . colType ,
96
+ endContextList : [ PhysicalColumnDefinitionContext . name ] ,
97
+ } ,
98
+ ] ) ;
85
99
}
86
100
87
101
exitFunctionNameCreate ( ctx : FunctionNameCreateContext ) {
0 commit comments