Package dap :: Package plugins :: Package sql

Package sql

Plugin for data stored in SQL servers.

This plugin should work with any database module that conforms with the
Python DB-API 2 specification:

    http://www.python.org/peps/pep-0249.html

You can find a list of database modules here:

    http://www.python.org/topics/database/modules.html

It currently has been tested with SQLite, MySQL and PostgreSQL.

TODO: add support for OFFSET and LIMIT if a slice is requested? This is
part of ANSI SQL, IIRC.

Classes

[hide private]

Handler

Functions

[hide private]

filter1(vars_)
Dynamic filter for converting special values into numbers.

split_dsn(location)
Split DSN into user, password, host, port and dbname.

parse_queries(queries, vars_, cols=None)
Build SQL query from DAP queries.

_get_conn(dsn)
Build the connection.

_conn_sqlite(location)
SQLite connection.

_conn_pgsql(location)
PostgreSQL connection.

_conn_mysql(location)
MySQL connection.

_conn_oracle(location)
Oracle connection.

_test()

Variables

[hide private]

__author__ = 'Roberto De Almeida <rob@pydap.org>'

extensions = '^.*\\.(sql|SQL)$'

DATETIME_DEFAULT_UNITS = 'years since 1-1-1'

TIMEDELTA_DEFAULT_UNITS = 'years'

MISSING_VALUE = -9999

Imports: os, ConfigParser, urllib, re, itertools, datetime, sys, coards.to_udunits, dap, dtypes, server.BaseHandler, util.safeeval.expr_eval, exceptions.ConstraintExpressionError, helper.parse_querystring

Function Details

[hide private]

filter1(vars_)

source code

Dynamic filter for converting special values into numbers.

split_dsn(location)

source code

Split DSN into user, password, host, port and dbname.

>>> print split_dsn('user:pass@host:80/db')
('user', 'pass', 'host', '80', 'db')
>>> print split_dsn('host/db')
(None, None, 'host', None, 'db')
>>> print split_dsn('user@host/db')
('user', None, 'host', None, 'db')
>>> print split_dsn('user:pass@host/db')
('user', 'pass', 'host', None, 'db')

parse_queries(queries, vars_, cols=None)

source code

Build SQL query from DAP queries.

>>> vars_ = ['index',  'site']
>>> parse_queries(['index>=11'], vars_)
'(index >= 11)'
>>> parse_queries(['site=~".*_St"'], vars_)
Traceback (most recent call last):
...
ConstraintExpressionError: 'Regular expressions disallowed!'
>>> parse_queries(['site=~".*_St"', 'index>=11'], vars_)
Traceback (most recent call last):
...
ConstraintExpressionError: 'Regular expressions disallowed!'
>>> parse_queries(['site={"Diamond_St", "Blacktail_Loop"}'], vars_)
"((site = 'Diamond_St') OR (site = 'Blacktail_Loop'))"
>>> parse_queries(['index={10, 12}'], vars_)
'((index = 10) OR (index = 12))'

_get_conn(dsn)

source code

Build the connection.

_conn_sqlite(location)

source code

SQLite connection.

_conn_pgsql(location)

source code

PostgreSQL connection.

_conn_mysql(location)

source code

MySQL connection.

_conn_oracle(location)

source code

Oracle connection.

_test()

source code

None

Variables Details

[hide private]

author

None

Value:

'Roberto De Almeida <rob@pydap.org>'

extensions

None

Value:

'^.*\\.(sql|SQL)$'

DATETIME_DEFAULT_UNITS

None

Value:

'years since 1-1-1'

TIMEDELTA_DEFAULT_UNITS

None

Value:

'years'

MISSING_VALUE

None

Value:

-9999