Databases

class mindsdb_sdk.databases.Database(server, name)

Bases: object

Allows to work with database (datasource): to use tables and make raw queries

To run native query At this moment query is just saved in Qeury object and not executed

>>> query = database.query('select * from table1') # returns Query

This command sends request to server to execute query and return dataframe

>>> df = query.fetch()

Has list of tables in .tables attribute.

query(sql: str) → mindsdb_sdk.query.Query

Make raw query to integration

Parameters

sql – sql of the query

Returns

Query object

class mindsdb_sdk.databases.Databases(api)

Bases: mindsdb_sdk.utils.objects_collection.CollectionBase

>>> databases.list()
>>> db = databases[0] # Database type object

# create

>>> db = databases.create('example_db',
...                                 type='postgres',
...                                 connection_args={'host': ''})

# drop database

>>> databases.drop('example_db')

# get existing

>>> db = databases.get('example_db')

create(name: str, engine: Union[str, mindsdb_sdk.handlers.Handler], connection_args: dict) → mindsdb_sdk.databases.Database

Create new integration and return it

Parameters

• name – Identifier for the integration to be created

• engine – Engine to be selected depending on the database connection.

• connection_args – {“key”: “value”} object with the connection parameters specific for each engine

Returns

created Database object

drop(name: str)

Delete integration

Parameters

name – name of integration

get(name: str) → mindsdb_sdk.databases.Database

Get integration by name

Parameters

name – name of integration

Returns

Database object

list() → List[mindsdb_sdk.databases.Database]

Show list of integrations (databases) on server

Returns

list of Database objects