Skip to content

Commit f89b4a5

Browse files
author
desiena
committed
Refactoring
1 parent 0d5d98b commit f89b4a5

File tree

3 files changed

+6
-44
lines changed

3 files changed

+6
-44
lines changed

fmdata/fmclient.py

Lines changed: 1 addition & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -657,8 +657,6 @@ def page_generator(
657657
records_retrieved = 0
658658

659659
while is_final_page is False:
660-
# TODO
661-
print("itero page generator", records_retrieved, offset, page_size, limit)
662660
# Calculate the limit for the next request
663661
if limit is None:
664662
# If the global limit is not defined we don't know how many records we have to retrieve
@@ -675,7 +673,6 @@ def page_generator(
675673

676674
limit_for_current_request = min(page_size, remaining)
677675

678-
print("chiamo request", offset, limit_for_current_request)
679676
client_response = fn_get_response(
680677
layout=layout,
681678
offset=offset,
@@ -687,7 +684,7 @@ def page_generator(
687684
layout=layout)
688685

689686
result.raise_exception_if_has_error()
690-
print("result", result)
687+
691688
if any(result.get_messages_iterator(search_codes=[FMErrorEnum.NO_RECORDS_MATCH_REQUEST])):
692689
response_entries_count = 0
693690
is_final_page = True
@@ -744,8 +741,6 @@ def portal_page_generator(
744741
records_retrieved = 0
745742

746743
while is_final_page is False:
747-
# TODO
748-
print("itero page generator", records_retrieved, offset, page_size, limit)
749744
# Calculate the limit for the next request
750745
if limit is None:
751746
# If the global limit is not defined we don't know how many records we have to retrieve
@@ -762,8 +757,6 @@ def portal_page_generator(
762757

763758
limit_for_current_request = min(page_size, remaining)
764759

765-
print("chiamo request", offset, limit_for_current_request)
766-
767760
portals = {
768761
portal_name: SinglePortalInput(offset=offset, limit=limit_for_current_request)
769762
}
@@ -777,8 +770,6 @@ def portal_page_generator(
777770

778771
result.raise_exception_if_has_error()
779772

780-
print("result", result)
781-
782773
response_record_count = len(result.response.data)
783774
if not response_record_count == 1:
784775
response_entries_count = 0

fmdata/orm.py

Lines changed: 0 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -186,7 +186,6 @@ def _is_sliced(self):
186186
return self._slice_start != 0 or self._slice_stop is not None
187187

188188
def _set_new_slice(self, start, stop):
189-
print("set new slice", start, stop)
190189
# Trick to manage multiple slicing before executing the query
191190
if stop is not None:
192191
if self._slice_stop is not None:
@@ -199,8 +198,6 @@ def _set_new_slice(self, start, stop):
199198
else:
200199
self._slice_start = self._slice_start + start
201200

202-
print("setted", self._slice_start, self._slice_stop)
203-
204201
def __getitem__(self, k):
205202
if isinstance(k, slice):
206203
if (k.start is not None and k.start < 0) or (k.stop is not None and k.stop < 0):
@@ -259,9 +256,6 @@ def create(self, **kwargs):
259256
portal.save()
260257

261258
def _execute_query(self):
262-
# TODO
263-
print("execute portal query")
264-
265259
offset = self._slice_start + 1
266260
limit = None
267261

@@ -809,7 +803,6 @@ def _is_sliced(self):
809803
return self._slice_start != 0 or self._slice_stop is not None
810804

811805
def _set_new_slice(self, start, stop):
812-
print("set new slice", start, stop)
813806
# Trick to manage multiple slicing before executing the query
814807
if stop is not None:
815808
if self._slice_stop is not None:
@@ -822,8 +815,6 @@ def _set_new_slice(self, start, stop):
822815
else:
823816
self._slice_start = self._slice_start + start
824817

825-
print("setted", self._slice_start, self._slice_stop)
826-
827818
def first(self):
828819
for obj in self[:1]:
829820
return obj
@@ -853,9 +844,6 @@ def _get_query(self):
853844
return query
854845

855846
def _execute_query(self):
856-
# TODO
857-
print("execute query")
858-
859847
offset = self._slice_start + 1
860848
limit = None
861849

@@ -1061,7 +1049,6 @@ def __new__(mcls, name, bases, namespace):
10611049

10621050
cls = super().__new__(mcls, name, bases, namespace)
10631051

1064-
# TODO probably cls.Meta is good enough
10651052
base_schema_cls: Type[FileMakerSchema] = get_meta_attribute("base_schema", bases,
10661053
namespace) or FileMakerSchema
10671054
schema_cls = type(f'{name}Schema', (base_schema_cls,), schema_fields)

tests/integration/test_server.py

Lines changed: 5 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -53,11 +53,10 @@ class Meta:
5353
client = fm_client
5454
layout = 'test_fmdata_student_layout'
5555

56-
# TODO required management?
57-
pk = fields.Str(required=False, data_key="PrimaryKey")
58-
full_name = fields.Str(required=False, data_key="FullName")
59-
enrollment_date = fields.Date(required=False, data_key="EnrollmentDate")
60-
GraduationYear = EmptyStringToNoneInteger(required=False, as_string=True, allow_none=True)
56+
pk = fields.Str(data_key="PrimaryKey")
57+
full_name = fields.Str(data_key="FullName")
58+
enrollment_date = fields.Date(data_key="EnrollmentDate")
59+
GraduationYear = EmptyStringToNoneInteger(as_string=True, allow_none=True)
6160

6261
test_fmdata_class_1 = PortalField(model=ClassPortal, name="test_fmdata_class_1")
6362

@@ -70,27 +69,12 @@ def test_reset_db(self):
7069
query=[{"PrimaryKey": "*"}]).raise_exception_if_has_error().found_set.delete_all_records()
7170
exam_layout.find(query=[{"PrimaryKey": "*"}]).raise_exception_if_has_error().found_set.delete_all_records()
7271

73-
# def test_mio(self):
74-
# # Create Students
75-
# #student = Student(record_id=53)
76-
# student = Student(full_name="Lorenzo", enrollment_date=datetime.date(2024,1,3), GraduationYear=2).save()
77-
#
78-
# student.GraduationYear = 3
79-
# student.save()
80-
#
81-
# student.refresh_from_db()
82-
# #student.delete()
83-
#
84-
# print(student.record_id)
85-
# print(student.mod_id)
86-
# print(student.pk)
87-
# pass
8872
def action(self, i):
8973
result_set = Student.objects.order_by("pk").find(full_name__raw="*")
9074
for item in result_set:
9175
print(i, item.pk, item.full_name)
9276

93-
def test_mio2(self):
77+
def test_0(self):
9478
result_set = (Student.objects.order_by("pk")
9579
.find(full_name__raw="*")
9680
.chunk_size(100)

0 commit comments

Comments
 (0)