CREATE DATABASE

Starting from Timeplus Enterprise 2.6, you can create a database to organize your streams, materialized views and other resources. The database is a logical container to help you to manage and query the data more efficiently.

When you create a database in a cluster, the database is automatically replicated to all the nodes in the cluster. You can create a database with the following SQL:

CREATE DATABASE IF NOT EXISTS my_database;

Once the database is created, you can create streams, materialized views, and other resources in the database by running USE my_database before creating the resources.

For example:

CREATE DATABASE my_database;

USE my_database;

CREATE STREAM my_stream (raw string);

INSERT INTO my_stream(raw) VALUES ('hello');

SELECT * FROM table(my_stream);
--if you are using other databases
SELECT * FROM table(my_database.my_stream);

Please note User-Defined Functions are global and not bound to a specific database.

External Database

Starting from Timeplus Enterprise 2.8, you can create an external database to connect to external MySQL and Iceberg databases.

MySQL Database

Syntax:

CREATE DATABASE mysql_database
SETTINGS
    type = 'mysql',
    address = 'localhost:port',
    user = 'root',
    password = 'password',
    database = 'my_database'

Then you can list all tables from the remote MySQL database:

SHOW STREAMS FROM mysql_database;

Or query them:

SELECT * FROM mysql_database.my_stream;

Iceberg Database

Syntax:

CREATE DATABASE <database_name>
SETTINGS
          type='iceberg',
          catalog_uri='<catalog_uri>',
          catalog_type='rest',
          warehouse='<warehouse_path>',
          storage_endpoint='<s3_endpoint>',
          rest_catalog_sigv4_enabled=<true|false>,
          rest_catalog_signing_region='<region>',
          rest_catalog_signing_name='<service_name>',
          use_environment_credentials=<true|false>,
          credential='<username:password>',
          catalog_credential='<username:password>',
          storage_credential='<username:password>';

Learn more

See also

• USE - Use a database
• SHOW DATABASES - Show databases
• DROP DATABASE - Drop databases