Lindorm:Use Python DB-API to develop applications

Step 1: Set connection parameters

connect_kw_args = {
    'lindorm_user': '<userName>',
    'lindorm_password': '<userPassword>',
    'database': '<database>'
}

Step 2: Open the connection

database_url = '<lindorm_sql_url>'

connection = phoenixdb.connect(database_url, autocommit=True, **connect_kw_args)

Create a table

with connection.cursor() as statement:
    sql = "CREATE TABLE IF NOT EXISTS test_python (c1 INTEGER, c2 INTEGER, PRIMARY KEY (c1))"
    statement.execute(sql)

Insert a single row

with connection.cursor() as statement:
    sql = "UPSERT INTO test_python (c1, c2) VALUES (1, 1)"
    statement.execute(sql)

Insert multiple rows

Use executemany() to insert multiple rows in a single call.

with connection.cursor() as statement:
    sql = "UPSERT INTO test_python (c1, c2) VALUES (?, ?)"
    statement.executemany(sql, [(2, 2), (3, 3)])

Update a row

with connection.cursor() as statement:
    sql = "UPSERT INTO test_python (c1, c2) VALUES (1, 10)"
    statement.execute(sql)

Delete rows

with connection.cursor() as statement:
    sql = "DELETE FROM test_python WHERE c1 = 2"
    statement.execute(sql)

Query data

fetchall() returns a list of tuples, one per row.

with connection.cursor() as statement:
    statement.execute("SELECT * FROM test_python")
    rows = statement.fetchall()
    for row in rows:
        print(row)   # e.g. (1, 10)

Drop a table

If your LindormTable version is later than 2.2.16 and earlier than 2.4.1, run OFFLINE TABLE before dropping the table.

with connection.cursor() as statement:
    # Required only for LindormTable versions > 2.2.16 and < 2.4.1
    statement.execute("OFFLINE TABLE test_python")
    statement.execute("DROP TABLE IF EXISTS test_python")

Close the connection

connection.close()

For the complete sample code, see the Python example on GitHub.