Skip to content

Commit a6ad1b0

Browse files
committed
test: New test for multiple lines on explicit buffer.
1 parent 4c877ef commit a6ad1b0

File tree

2 files changed

+24
-1
lines changed

2 files changed

+24
-1
lines changed

c-questdb-client

test/test.py

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -185,6 +185,29 @@ def test_flush_4(self):
185185
sender.row('tbl1', symbols={'a': 'b'})
186186
sender.flush(buffer=None, clear=False)
187187

188+
def test_two_rows_explicit_buffer(self):
189+
with Server() as server, qi.Sender('localhost', server.port) as sender:
190+
server.accept()
191+
self.assertEqual(server.recv(), [])
192+
buffer = sender.new_buffer()
193+
buffer.row(
194+
'line_sender_buffer_example2',
195+
symbols={'id': 'Hola'},
196+
columns={'price': '111222233333i', 'qty': 3.5},
197+
at=qi.TimestampNanos(111222233333))
198+
buffer.row(
199+
'line_sender_example',
200+
symbols={'id': 'Adios'},
201+
columns={'price': '111222233343i', 'qty': 2.5},
202+
at=qi.TimestampNanos(111222233343))
203+
exp = (
204+
'line_sender_buffer_example2,id=Hola price="111222233333i",qty=3.5 111222233333\n'
205+
'line_sender_example,id=Adios price="111222233343i",qty=2.5 111222233343\n')
206+
self.assertEqual(str(buffer), exp)
207+
sender.flush(buffer)
208+
msgs = server.recv()
209+
bexp = [msg.encode('utf-8') for msg in exp.rstrip().split('\n')]
210+
self.assertEqual(msgs, bexp)
188211

189212
def test_independent_buffer(self):
190213
buf = qi.Buffer()

0 commit comments

Comments
 (0)