Skip to content

IGNITE-13911 Asyncio version of client #21

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
ivandasch wants to merge 14 commits into from
Closed

IGNITE-13911 Asyncio version of client #21

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
14 commits
Select commit Hold shift + click to select a range
889b764
IGNITE-13911 Create asyncs for datatypes and queries. Create AioConne…
ivandasch Feb 24, 2021
d12b33b
IGNITE-13911 Common and security tests.
ivandasch Mar 3, 2021
23dc2f7
IGNITE-13911 Implement affinity tests
ivandasch Mar 9, 2021
b7ec683
IGNITE-13911 Refactor cache pt. 1
ivandasch Mar 10, 2021
a61f077
IGNITE-13911 Refactor cache pt. 2
ivandasch Mar 10, 2021
4ba7f8d
IGNITE-13911 Refactor connection
ivandasch Mar 10, 2021
d4a014f
IGNITE-13911 Refactor client.
ivandasch Mar 11, 2021
1c4dada
IGNITE-13911 Refactor connection pt.2
ivandasch Mar 11, 2021
5bc608a
IGNITE-13911 Minor formatting.
ivandasch Mar 11, 2021
5fd3c9f
IGNITE-13911 Refactor connection pt.3
ivandasch Mar 11, 2021
6d358a2
IGNITE-13911 Fix concurrency bug with aio connection. Simplify synchr…
ivandasch Mar 16, 2021
d0dab2c
IGNITE-13911 Minor.
ivandasch Mar 16, 2021
e472d3c
IGNITE-13911 Fix unnessesary attrs wrapping.
ivandasch Mar 16, 2021
1a66cdb
IGNITE-13911 Speedup partition lookup.
ivandasch Mar 16, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions .gitignore
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@
*.so
build
distr
docs/generated
tests/config/*.xml
junit*.xml
pyignite.egg-info
Expand Down
3 changes: 3 additions & 0 deletions .travis.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -43,6 +43,9 @@ jobs:
- python: '3.8'
arch: amd64
env: TOXENV=py38
- python: '3.8'
arch: amd64
env: TOXENV=codestyle
- python: '3.9'
arch: amd64
env: TOXENV=py39
Expand Down
76 changes: 38 additions & 38 deletions examples/create_binary.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,44 +23,44 @@
client.connect('127.0.0.1', 10800)

student_cache = client.create_cache({
PROP_NAME: 'SQL_PUBLIC_STUDENT',
PROP_SQL_SCHEMA: 'PUBLIC',
PROP_QUERY_ENTITIES: [
{
'table_name': 'Student'.upper(),
'key_field_name': 'SID',
'key_type_name': 'java.lang.Integer',
'field_name_aliases': [],
'query_fields': [
{
'name': 'SID',
'type_name': 'java.lang.Integer',
'is_key_field': True,
'is_notnull_constraint_field': True,
},
{
'name': 'NAME',
'type_name': 'java.lang.String',
},
{
'name': 'LOGIN',
'type_name': 'java.lang.String',
},
{
'name': 'AGE',
'type_name': 'java.lang.Integer',
},
{
'name': 'GPA',
'type_name': 'java.math.Double',
},
],
'query_indexes': [],
'value_type_name': 'SQL_PUBLIC_STUDENT_TYPE',
'value_field_name': None,
},
],
})
PROP_NAME: 'SQL_PUBLIC_STUDENT',
PROP_SQL_SCHEMA: 'PUBLIC',
PROP_QUERY_ENTITIES: [
{
'table_name': 'Student'.upper(),
'key_field_name': 'SID',
'key_type_name': 'java.lang.Integer',
'field_name_aliases': [],
'query_fields': [
{
'name': 'SID',
'type_name': 'java.lang.Integer',
'is_key_field': True,
'is_notnull_constraint_field': True,
},
{
'name': 'NAME',
'type_name': 'java.lang.String',
},
{
'name': 'LOGIN',
'type_name': 'java.lang.String',
},
{
'name': 'AGE',
'type_name': 'java.lang.Integer',
},
{
'name': 'GPA',
'type_name': 'java.math.Double',
},
],
'query_indexes': [],
'value_type_name': 'SQL_PUBLIC_STUDENT_TYPE',
'value_field_name': None,
},
],
})


class Student(
Expand Down
2 changes: 1 addition & 1 deletion examples/sql.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -280,7 +280,7 @@
field_data = list(*result)

print('City info:')
for field_name, field_value in zip(field_names*len(field_data), field_data):
for field_name, field_value in zip(field_names * len(field_data), field_data):
print('{}: {}'.format(field_name, field_value))
# City info:
# ID: 3802
Expand Down
3 changes: 3 additions & 0 deletions pyignite/__init__.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,4 +14,7 @@
# limitations under the License.

from pyignite.client import Client
from pyignite.aio_client import AioClient
from pyignite.binary import GenericObjectMeta

__version__ = '0.4.0-dev'
Loading