Skip to content

Commit 821d7f2

Browse files
committed
Update Fusion docs and change expression to statement
1 parent d46eba3 commit 821d7f2

File tree

2 files changed

+9
-7
lines changed

2 files changed

+9
-7
lines changed

singlestoredb/fusion/README.md

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,9 @@ time.
1010
By default, Fusion SQL commands are not processed by the client. They
1111
must be enabled by setting an environment variable.
1212
```
13-
SINGLESTOREDB_FUSION_ENABLED=1
13+
import os
14+
15+
os.environ['SINGLESTOREDB_FUSION_ENABLED']='1'
1416
```
1517

1618
## Writing Fusion SQL handler classes
@@ -42,7 +44,7 @@ class ListDirHandler(SQLHandler):
4244

4345
def run(self, params: Dict[str, Any]) -> Optional[result.FusionSQLResult]:
4446
# Create a result object
45-
res = self.create_result()
47+
res = result.FusionSQLResult()
4648

4749
# Add a field to the results
4850
res.add_field('Name', result.STRING)
@@ -271,7 +273,7 @@ class CreateWorkspaceGroupHandler(SQLHandler):
271273
firewall_ranges=params['with_firewall_ranges'],
272274
)
273275

274-
return self.create_result()
276+
return None
275277

276278

277279
CreateWorkspaceGroupHandler.register()

singlestoredb/fusion/handler.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@
3333
close_paren = ws* ")" ws*
3434
open_repeats = ws* ~r"[\(\[\{]" ws*
3535
close_repeats = ws* ~r"[\)\]\}]" ws*
36-
expression = ~r"[\s\S]*" ws*
36+
statement = ~r"[\s\S]*" ws*
3737
table = ~r"(?:([A-Za-z0-9_\-]+)|`([^\`]+)`)(?:\.(?:([A-Za-z0-9_\-]+)|`([^\`]+)`))?" ws*
3838
column = ~r"(?:([A-Za-z0-9_\-]+)|`([^\`]+)`)(?:\.(?:([A-Za-z0-9_\-]+)|`([^\`]+)`))?" ws*
3939
link_name = ~r"(?:([A-Za-z0-9_\-]+)|`([^\`]+)`)(?:\.(?:([A-Za-z0-9_\-]+)|`([^\`]+)`))?" ws*
@@ -77,7 +77,7 @@
7777
'<file-type>': r'''
7878
file_type = { FILE | FOLDER }
7979
''',
80-
'<expression>': '',
80+
'<statement>': '',
8181
}
8282

8383
BUILTIN_DEFAULTS = { # type: ignore
@@ -759,9 +759,9 @@ def visit_init(self, node: Node, visited_children: Iterable[Any]) -> Any:
759759
_, out, *_ = visited_children
760760
return out
761761

762-
def visit_expression(self, node: Node, visited_children: Iterable[Any]) -> Any:
762+
def visit_statement(self, node: Node, visited_children: Iterable[Any]) -> Any:
763763
out = ' '.join(flatten(visited_children)).strip()
764-
return {'expression': out}
764+
return {'statement': out}
765765

766766
def visit_order_by(self, node: Node, visited_children: Iterable[Any]) -> Any:
767767
"""Handle ORDER BY."""

0 commit comments

Comments
 (0)