Skip to content

Commit

Permalink
Merge branch 'develop'
Browse files Browse the repository at this point in the history
* develop:
  feature: add note
  feature: update documentation feature: adde samples
  • Loading branch information
klich3 committed Jun 27, 2024
2 parents ff71287 + 260abac commit 0dd3a95
Show file tree
Hide file tree
Showing 3 changed files with 120 additions and 1 deletion.
16 changes: 15 additions & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -107,10 +107,24 @@ Find and retrieve records, in a collection.

```python
rs.get(collection="delete_fodders1")

# or
rs.get("delete_fodders1")
# Get wildcar

# Get wildcard
rs.get("delete_*")

# Get wildcard in collection
rs.get("*")

# Get wildcard in key (see sample in Samples/queries.py)
rs.get("delete_fodders1", "*")

# Get only auto incremented rows (see sample in Samples/queries.py)
rs.get("delete_fodders1", "?")

# get only keys
rs.get("delete_fodders1", "*", Rocketstore._KEYS)
```

__Collection__ to search. If no collection name is given, get will return a list of data base assets: collections and sequences etc.
Expand Down
102 changes: 102 additions & 0 deletions Samples/queries.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,102 @@
"""
█▀ █▄█ █▀▀ █░█ █▀▀ █░█
▄█ ░█░ █▄▄ █▀█ ██▄ ▀▄▀
Author: <Anton Sychev> (anton at sychev dot xyz)
queries.py (c) 2024
Created: 2024-01-11 20:49:20
Desc: queries samples
Docs: documentation
"""


import os
from Rocketstore import Rocketstore

rs = Rocketstore(**{"data_storage_area": os.path.join(os.getcwd(), "rwdb")})

rs.post(
"bl_54e2e7228e9e44ec9e17e7848759e867",
"",
{"content": "global item"},
Rocketstore._ADD_AUTO_INC,
)
rs.post(
"bl_54e2e7228e9e44ec9e17e7848759e867",
"",
{"content": "global item 2"},
Rocketstore._ADD_AUTO_INC,
)

rs.post(
"bl_54e2e7228e9e44ec9e17e7848759e867",
"ses_784dac38ee0c4f709bddc0deb0b421bd",
{"content": "user session 1"},
Rocketstore._ADD_AUTO_INC,
)
rs.post(
"bl_54e2e7228e9e44ec9e17e7848759e867",
"ses_784dac38ee0c4f709bddc0deb0b421bd",
{"content": "user session 2"},
Rocketstore._ADD_AUTO_INC,
)
rs.post(
"bl_54e2e7228e9e44ec9e17e7848759e867",
"ses_784dac38ee0c4f709bddc0deb0b421bd",
{"content": "user session 3"},
Rocketstore._ADD_AUTO_INC,
)
rs.post(
"bl_54e2e7228e9e44ec9e17e7848759e867",
"ses_784dac38ee0c4f709bddc0deb0b421bd",
{"content": "user session 4"},
Rocketstore._ADD_AUTO_INC,
)
rs.post(
"bl_54e2e7228e9e44ec9e17e7848759e867",
"ses_784dac38ee0c4f709bddc0deb0b421bd",
{"content": "user session 5"},
Rocketstore._ADD_AUTO_INC,
)
rs.post(
"bl_54e2e7228e9e44ec9e17e7848759e867",
"ses_784dac38ee0c4f709bddc0deb0b421bd",
{"content": "user session 6"},
Rocketstore._ADD_AUTO_INC,
)


rs.get("bl_54e2e7228e9e44ec9e17e7848759e867")
"""
{'count': 7, 'key': ['6-ses_784dac38ee0c4f709bddc0deb0b421bd', '7-ses_784dac38ee0c4f709bddc0deb0b421bd', '1', '5-ses_784dac38ee0c4f709bddc0deb0b421bd', '3-ses_784dac38ee0c4f709bddc0deb0b421bd', '4-ses_784dac38ee0c4f709bddc0deb0b421bd', '2'], 'result': [{'content': 'user session 1'}, {'content': 'user session 1'}, {'content': 'global item'}, {'content': 'user session 1'}, {'content': 'user session 1'}, {'content': 'user session 1'}, {'content': 'global item 2'}]}
"""

rs.get("bl_54e2e7228e9e44ec9e17e7848759e867",
"*ses_784dac38ee0c4f709bddc0deb0b421bd")
"""
{'count': 5, 'key': ['6-ses_784dac38ee0c4f709bddc0deb0b421bd', '7-ses_784dac38ee0c4f709bddc0deb0b421bd', '5-ses_784dac38ee0c4f709bddc0deb0b421bd', '3-ses_784dac38ee0c4f709bddc0deb0b421bd', '4-ses_784dac38ee0c4f709bddc0deb0b421bd'], 'result': [{'content': 'user session 1'}, {'content': 'user session 1'}, {'content': 'user session 1'}, {'content': 'user session 1'}, {'content': 'user session 1'}]}
"""

rs.get("bl_54e2e7228e9e44ec9e17e7848759e867", "*")
"""
{'count': 7, 'key': ['6-ses_784dac38ee0c4f709bddc0deb0b421bd', '7-ses_784dac38ee0c4f709bddc0deb0b421bd', '1', '5-ses_784dac38ee0c4f709bddc0deb0b421bd', '3-ses_784dac38ee0c4f709bddc0deb0b421bd', '4-ses_784dac38ee0c4f709bddc0deb0b421bd', '2'], 'result': [{'content': 'user session 1'}, {'content': 'user session 1'}, {'content': 'global item'}, {'content': 'user session 1'}, {'content': 'user session 1'}, {'content': 'user session 1'}, {'content': 'global item 2'}]}
"""

rs.get("bl_54e2e7228e9e44ec9e17e7848759e867", "?", Rocketstore._KEYS)
"""
{'count': 2, 'key': ['1', '2']}
"""

rs.get("bl_54e2e7228e9e44ec9e17e7848759e867", "*", Rocketstore._KEYS)
"""
{'count': 7, 'key': ['6-ses_784dac38ee0c4f709bddc0deb0b421bd', '7-ses_784dac38ee0c4f709bddc0deb0b421bd', '1', '5-ses_784dac38ee0c4f709bddc0deb0b421bd', '3-ses_784dac38ee0c4f709bddc0deb0b421bd', '4-ses_784dac38ee0c4f709bddc0deb0b421bd', '2']}
"""

rs.get("bl_54e2e7228e9e44ec9e17e7848759e867", "?", Rocketstore._KEYS)
"""
{'count': 2, 'key': ['1', '2']}
"""
rs.get("bl_54e2e7228e9e44ec9e17e7848759e867", "?")
"""
{'count': 2, 'key': ['1', '2'], 'result': [{'content': 'global item'}, {'content': 'global item 2'}]}
"""
3 changes: 3 additions & 0 deletions src/Rocketstore/Rocketstore.py
Original file line number Diff line number Diff line change
Expand Up @@ -215,6 +215,9 @@ def get(
NB: Files may have been removed manually and should be removed from the cache
"""

# TODO: add regexpt search in key

keys = []
uncache = []
records = []
Expand Down

0 comments on commit 0dd3a95

Please sign in to comment.