pysqream API reference¶

The SQream Python connector allows Python programs to connect to SQream DB.

pysqream conforms to Python DB-API specifications PEP-249

The main module is pysqream, which contains the Connection() class.

connect(host, port, database, username, password, clustered = False, use_ssl = False, service='sqream', reconnect_attempts=3, reconnect_interval=10)¶

Creates a new Connection() object and connects to SQream DB.

host: SQream DB hostname or IP
port: SQream DB port
database: database name
username: Username to use for connection
password: Password for username
clustered: Connect through load balancer, or direct to worker (Default: false - direct to worker)
use_ssl: use SSL connection (default: false)
service: Optional service queue (default: ‘sqream’)
reconnect_attempts: Number of reconnection attempts to attempt before closing the connection
reconnect_interval: Time in seconds between each reconnection attempt

class Connection¶

arraysize¶: Specifies the number of rows to fetch at a time with fetchmany(). Defaults to 1 - one row at a time.

rowcount¶: Unused, always returns -1.

description¶

Read-only attribute that contains result set metadata.

This attribute is populated after a statement is executed.

Value	Description
`name`	Column name
`type_code`	Internal type code
`display_size`	Not used - same as `internal_size`
`internal_size`	Data size in bytes
`precision`	Precision of numeric data (not used)
`scale`	Scale for numeric data (not used)
`null_ok`	Specifies if `NULL` values are allowed for this column

execute(self, query, params=None)¶

Execute a statement.

Parameters are not supported

self: Connection()
query: statement or query text
params: Unused

executemany(self, query, rows_or_cols=None, data_as='rows', amount=None)¶

Prepares a statement and executes it against all parameter sequences found in rows_or_cols.

self: Connection()
query: INSERT statement
rows_or_cols: Data buffer to insert. This should be a sequence of lists or tuples.
data_as: (Optional) Read data as rows or columns
amount: (Optional) count of rows to insert

close(self)¶

Close a statement and connection. After a statement is closed, it must be reopened by creating a new cursor.

self: Connection()

cursor(self)¶

Create a new Connection() cursor.

We recommend creating a new cursor for every statement.

self: Connection()

fetchall(self, data_as='rows')¶

Fetch all remaining records from the result set.

An empty sequence is returned when no more rows are available.

self: Connection()
data_as: (Optional) Read data as rows or columns

fetchone(self, data_as='rows')¶

Fetch one record from the result set.

An empty sequence is returned when no more rows are available.

self: Connection()
data_as: (Optional) Read data as rows or columns

fetchmany(self, size=[Connection.arraysize], data_as='rows')¶

Fetches the next several rows of a query result set.

An empty sequence is returned when no more rows are available.

self: Connection()
size: Number of records to fetch. If not set, fetches Connection.arraysize (1 by default) records
data_as: (Optional) Read data as rows or columns

__iter__()¶: Makes the cursor iterable.

apilevel = '2.0': String constant stating the supported API level. The connector supports API “2.0”.

threadsafety = 1: Level of thread safety the interface supports. pysqream currently supports level 1, which states that threads can share the module, but not connections.

paramstyle = 'qmark': The placeholder marker. Set to qmark, which is a question mark (?).