hhdb数据库介绍(9-12)

alter table table_name change shard column new_column；

mysql> alter table sbtest1 change shard column k;
Query OK, 0 rows affected (2 min 2.27 sec)

root@127.0.0.1:hotdb 5.7.25 06:44:26> select * from mysql.user\G
*************************** 1. row ***************************
                    HOST: %
                    USER: root
             SELECT_PRIV: Y
             INSERT_PRIV: Y
             UPDATE_PRIV: Y
             DELETE_PRIV: Y
             CREATE_PRIV: Y
               DROP_PRIV: Y
             RELOAD_PRIV: Y
           SHUTDOWN_PRIV: N
            PROCESS_PRIV: N
               FILE_PRIV: Y
              GRANT_PRIV: Y
         REFERENCES_PRIV: Y
              INDEX_PRIV: Y
              ALTER_PRIV: Y
            SHOW_DB_PRIV: Y
              SUPER_PRIV: Y
   CREATE_TMP_TABLE_PRIV: N
        LOCK_TABLES_PRIV: N
            EXECUTE_PRIV: Y
         REPL_SLAVE_PRIV: N
        REPL_CLIENT_PRIV: N
        CREATE_VIEW_PRIV: Y
          SHOW_VIEW_PRIV: Y
     CREATE_ROUTINE_PRIV: Y
      ALTER_ROUTINE_PRIV: Y
        CREATE_USER_PRIV: Y
              EVENT_PRIV: N
            TRIGGER_PRIV: Y
  CREATE_TABLESPACE_PRIV: N
                SSL_TYPE: 
              SSL_CIPHER: 
             X509_ISSUER: 
            X509_SUBJECT: 
           MAX_QUESTIONS: 0
             MAX_UPDATES: 0
         MAX_CONNECTIONS: 5000
    MAX_USER_CONNECTIONS: 0
                  PLUGIN: mysql_native_password
   AUTHENTICATION_STRING: *7453ab8f069c2d2bafa64669db5771059e3fc946
        PASSWORD_EXPIRED: N
   PASSWORD_LAST_CHANGED: 2022-12-12 00:00:00
       PASSWORD_LIFETIME: NULL
          ACCOUNT_LOCKED: N
        CREATE_ROLE_PRIV: N
          DROP_ROLE_PRIV: N
  PASSWORD_REUSE_HISTORY: NULL
     PASSWORD_REUSE_TIME: NULL
PASSWORD_REQUIRE_CURRENT: NULL
         USER_ATTRIBUTES: NULL
1 row in set (0.00 sec)

CREATE [PUBLIC] DATABASE LINK link_name
    CONNECT TO remote_username IDENTIFIED BY 'remote_password'
    USING 'jdbcurl'
    WITH 'driver=oracle.jdbc.driver.OracleDriver;jar=ojdbc8.jar,ucp.jar;';

CREATE [PUBLIC] DATABASE LINK link_name 
    USING 'file' 
    WITH 'format=csv;location=/data/csv_data';

DEPTNO:int,NAME:string
10,"Sales"
20,"Marketing"
30,"Accounts"

MySQL> CREATE DATABASE LINK linkname1 CONNECT TO test IDENTIFIED BY 'test' USING 'jdbc:oracle:thin:@//192.168.240.66:1521/pdb01' WITH 'driver=oracle.jdbc.driver.OracleDriver;jar=ojdbc8.jar,ucp.jar;';
-- 创建名为linkname1的DBLINK，通过用户test连接Oracle数据库

MySQL> CREATE PUBLIC DATABASE LINK public_linkname1 CONNECT TO test IDENTIFIED BY 'test' USING 'jdbc:oracle:thin:@//192.168.240.66:1521/pdb01' WITH 'driver=oracle.jdbc.driver.OracleDriver;jar=ojdbc8.jar,ucp.jar;';
-- 创建名为public_linkname1的PUBLIC DBLINK，通过用户test连接Oracle数据库

MySQL> CREATE DATABASE LINK linkname2 CONNECT TO test IDENTIFIED BY 'test' USING 'jdbc:mysql://192.168.240.66:3323/hotdb';
-- 创建名为linkname2的DBLINK，通过用户test连接MySQL的hotdb数据库

MySQL> CREATE PUBLIC DATABASE LINK public_linkname2 CONNECT TO test IDENTIFIED BY 'test' USING 'jdbc:mysql://192.168.240.66:3323/hotdb';
-- 创建名为public_linkname2的PUBLIC DBLINK，通过用户test连接MySQL的hotdb数据库

ERROR: [CREATE] command denied to user '<数据库用户>' to database link '<dblink名>'

ERROR: duplicate database link name

<表名>@link_name

MySQL> SELECT * FROM table1@linkname1;
-- 向linkname1内的表table1查询数据

MySQL> SELECT * FROM "TestA"@linkname2;
-- 向linkname2内的表“TestA”（大小写敏感的表名）查询数据

MySQL> SELECT * FROM table0 join table1@linkname1 on join_condition;
-- 查询table0与linkname1内的表table1的join关联，根据一定的join条件进行查询

MySQL> INSERT INTO table1@linkname2 values(aaa,bbb,ccc);
-- 向linkname2内的表table1插入数据：

MySQL> UPDATE table1@linkname2 set xxx=yyy where aaa=bbb; 
-- 向linkname2内的表table1更新数据：

MySQL> DELETE from table1@linkname2 where xxx=yyy;
-- 向linkname2内的表table1删除数据：

ERROR: could not resolve the JDBC connect specified

<文件名>@link_name
-- <文件名>：填写存放在计算节点对应目录下，需要执行操作的CSV文件名；
-- link_name：填写创建DBLINK时配置的link_name；
-- 执行操作时，会去对应DBLINK配置的路径下寻找该文件名对应的文件；

SELECT * FROM file1@linkname1;
-- 查询名为linkname1的DBLINK链接下的file1文件数据

SELECT * FROM table0 JOIN file1@linkname1 on join_condition;
-- 从内部表table0和名为linkname1的DBLINK连接的外部文件file1中，根据特定的JOIN关联条件执行联接查询

SELECT * FROM table0 WHERE id in (select id from file1@linkname1);
-- 查询内部表table0中与DBLINK外部文件file1中id字段匹配的所有数据

SELECT * FROM file1@linkname1 WHERE id in (select id from table0);
-- 查询DBLINK外部文件file1数据中与内部表table0中id字段匹配的所有数据

INSERT INTO table0 SELECT * FROM file1@linkname1;
-- INSERT INTO table0：表示要将数据插入到名为“table0”的内部表中
-- SELECT * FROM file1@linkname1：表示要从位于DBLINK链接“linkname1”的外部文件“file1”中选择所有数据。
-- 通过这个语句，将文件“file1”中的数据插入到表“table0”中

UPDATE table0 JOIN file1@linkname1 on join_condition set table0.xxx=file1@linkname1.xxx WHERE file1@linkname1.id=1;
-- 通过连接条件，将内部表table0中与外部文件file1通过名为linkname1的DBLINK连接的数据进行修改；
-- 将内部表table0的字段xxx更新为外部文件file1中id为1的记录对应的字段xxx的值

ALTER [PUBLIC] DATABASE LINK link_name 
    CONNECT TO remote_username IDENTIFIED BY 'remote_password' 
    USING 'jdbcurl' 
    [ WITH 'driver=oracle.jdbc.driver.OracleDriver;jar=ojdbc8.jar,ucp.jar;' ];

ALTER [PUBLIC] DATABASE LINK link_name 
    USING 'file' 
    WITH 'format=csv;location=/data/csv_data';

MySQL> ALTER DATABASE LINK linkname1 CONNECT TO test IDENTIFIED BY 'test' USING 'jdbc:oracle:thin:@//192.168.240.66:1521/pdb01' WITH 'driver=oracle.jdbc.driver.OracleDriver;jar=ojdbc8.jar,ucp.jar;';
-- 修改名为linkname1的DBLINK（Oracle），更新remote_username、remote_password、jdbcurl、driver的信息。

MySQL> ALTER PUBLIC DATABASE LINK public_linkname1 CONNECT TO test IDENTIFIED BY 'test' USING 'jdbc:oracle:thin:@//192.168.240.66:1521/pdb01' WITH 'driver=oracle.jdbc.driver.OracleDriver;jar=ojdbc8.jar,ucp.jar;';
-- 修改名为public_linkname1的PUBLIC DBLINK（Oracle），更新remote_username、remote_password、jdbcurl、driver的信息。

MySQL> ALTER DATABASE LINK linkname2 CONNECT TO test IDENTIFIED BY 'test' USING 'jdbc:mysql://192.168.240.66:3323/hotdb';
-- 修改名为linkname2的DBLINK（MySQL），更新remote_username、remote_password、jdbcurl的信息。

MySQL> ALTER PUBLIC DATABASE LINK linkname2 CONNECT TO test IDENTIFIED BY 'test' USING 'jdbc:mysql://192.168.240.66:3323/hotdb';
-- 修改名为public_linkname2的PUBLIC DBLINK（MySQL），更新remote_username、remote_password、jdbcurl的信息。

DROP [PUBLIC] DATABASE LINK link_name;

MySQL> DROP DBLINK linkname1;
-- 删除名为linkname1的DBLINK。

MySQL> DROP PUBLIC DBLINK linkname1;
-- 删除名为linkname1的PUBLIC DBLINK。

ERROR: [DROP] command denied to user '<数据库用户>' to database link '<dblink名>'