Using Apache Phoenix to store and access data
Also available as:
PDF

Example of Phoenix Python library

Following code is an example of Phoenix Python library.

db = phoenixdb.connect('http://localhost:8765', autocommit=True)

with db.cursor() as cursor:

cursor.execute("DROP TABLE IF EXISTS test")

cursor.execute("CREATE TABLE test (id INTEGER PRIMARY KEY, text VARCHAR)")

cursor.executemany("UPSERT INTO test VALUES (?, ?)", [[i, 'text {}'.format(i)] for i in range(10)])

with db.cursor() as cursor:

cursor.itersize = 4

cursor.execute("SELECT * FROM test WHERE id>1 ORDER BY id")

self.assertEqual(cursor.fetchall(), [[i, 'text {}'.format(i)] for i in range(2, 10)])

db.close()