12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061 |
- # Copyright Materialize, Inc. and contributors. All rights reserved.
- #
- # Use of this software is governed by the Business Source License
- # included in the LICENSE file at the root of this repository.
- #
- # As of the Change Date specified in that file, in accordance with
- # the Business Source License, use of this software will be governed
- # by the Apache License, Version 2.0.
- $ set-sql-timeout duration=1s
- #
- # Test that CREATE SOURCE can be used to direct the tables to another schema
- #
- > CREATE SECRET mysqlpass AS '${arg.mysql-root-password}'
- > CREATE CONNECTION mysql_conn TO MYSQL (
- HOST mysql,
- USER root,
- PASSWORD SECRET mysqlpass
- )
- $ mysql-connect name=mysql url=mysql://root@mysql password=${arg.mysql-root-password}
- $ mysql-execute name=mysql
- DROP DATABASE IF EXISTS public;
- CREATE DATABASE public;
- USE public;
- CREATE TABLE t1 (f1 INTEGER);
- INSERT INTO t1 VALUES (1);
- CREATE TABLE t2 (f1 INTEGER);
- INSERT INTO t2 VALUES (2);
- > DROP SCHEMA IF EXISTS schema1
- > CREATE SCHEMA schema1
- > CREATE SOURCE mz_source FROM MYSQL CONNECTION mysql_conn;
- > CREATE TABLE schema1.t1 FROM SOURCE mz_source (REFERENCE public.t1);
- > CREATE TABLE schema1.t2 FROM SOURCE mz_source (REFERENCE public.t2);
- # Wait for snapshot to be complete
- > SELECT COUNT(*) > 0 FROM schema1.t1;
- true
- $ mysql-execute name=mysql
- INSERT INTO t1 SELECT * FROM t1;
- INSERT INTO t2 SELECT * FROM t2;
- > SELECT * FROM schema1.t1;
- 1
- 1
- > SELECT * FROM schema1.t2;
- 2
- 2
- > DROP SCHEMA schema1 CASCADE;
|