Skip to content

Commit 23905fd

Browse files
committed
RDBC-769 TypedBulkInsert::canCreateSimpleTimeSeries2
1 parent b2ccda0 commit 23905fd

File tree

1 file changed

+30
-0
lines changed

1 file changed

+30
-0
lines changed

ravendb/tests/jvm_migrated_tests/client_tests/time_series_tests/test_typed_bulk_insert.py

Lines changed: 30 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -270,3 +270,33 @@ def test_can_create_time_series_without_passing_name(self):
270270

271271
self.assertEqual(1, len(names))
272272
self.assertEqual("StockPrices", names[0])
273+
274+
def test_can_create_simple_time_series_2(self):
275+
base_line = RavenTestHelper.utc_this_month()
276+
document_id = "users/ayende"
277+
278+
with self.store.bulk_insert() as bulk_insert:
279+
user = User(name="Oren")
280+
bulk_insert.store_as(user, document_id)
281+
282+
measure = TypedTimeSeriesEntry()
283+
measure.timestamp = base_line + timedelta(minutes=1)
284+
measure.value = HeartRateMeasure(59)
285+
measure.tag = "watches/fitbit"
286+
287+
with bulk_insert.typed_time_series_for(
288+
HeartRateMeasure, document_id, "heartrate"
289+
) as time_series_bulk_insert:
290+
time_series_bulk_insert.append_single(
291+
base_line + timedelta(minutes=1), HeartRateMeasure(59), "watches/fitbit"
292+
)
293+
time_series_bulk_insert.append_single(
294+
base_line + timedelta(minutes=2), HeartRateMeasure(60), "watches/fitbit"
295+
)
296+
time_series_bulk_insert.append_single(
297+
base_line + timedelta(minutes=2), HeartRateMeasure(61), "watches/fitbit"
298+
)
299+
300+
with self.store.open_session() as session:
301+
val = session.typed_time_series_for(HeartRateMeasure, document_id, "heartrate").get()
302+
self.assertEqual(2, len(val))

0 commit comments

Comments
 (0)