ndbcluster operator

╰+哭是因爲堅強的太久メ 2022-01-29 04:39 157阅读 0赞

# [ndbcluster operator][] #

import java.sql.SQLException;
    
    /************************************************
     * @ClassName: NdbClusterOperator.java
     * @Tables:
     * @Author: wyl
     * @CreateDate: 2019/5/20
     ***********************************************/
    public class NdbClusterOperator {
         
    
        /**
         *  在任何给定时间，每个NDB群集实例只能有一个日志文件组
         * @param isCreate
         * @param logFileName
         * @param initSize 设置日志文件的初始大小
         * @param bufferSize
         * @param dbUtil
         */
        public static void createOrAlterdLogGroup(boolean isCreate, String logFileName, Integer initSize, Integer bufferSize, DBUtil dbUtil){
         
            checkArgument(logFileName);
            StringBuilder logSql = new StringBuilder();
            logSql.append(createOrAlter(isCreate));
            logSql.append("LOGFILE GROUP log_tk ADD UNDOFILE '");
            logSql.append(logFileName);
            logSql.append("' ");
            if (null != initSize){
         
                logSql.append("INITIAL_SIZE ");
                logSql.append(initSize);
                logSql.append("M");
            }
            if (null != bufferSize){
         
                logSql.append("UNDO_BUFFER_SIZE  ");
                logSql.append(bufferSize);
                logSql.append("M");
            }
            logSql.append("ENGINE NDBCLUSTER;");
            try {
         
                dbUtil.executeUpdate(logSql.toString(), null);
            } catch (SQLException e) {
         
               e.printStackTrace();
            }
    
        }
    
        public static void createTableSpace(boolean isCreate, String spaceName, String dataFileName, Integer initSize, DBUtil dbUtil){
         
            checkArgument(spaceName);
            StringBuilder spaceSql = new StringBuilder();
            spaceSql.append(createOrAlter(isCreate));
            spaceSql.append("TABLESPACE ");
            spaceSql.append(spaceName);
    
            spaceSql.append(" ADD DATAFILE '");
            spaceSql.append(dataFileName);
            spaceSql.append("' ");
            if (isCreate){
         
                spaceSql.append("USE LOGFILE GROUP log_tk");
            }
            if (null != initSize){
         
                spaceSql.append("INITIAL_SIZE ");
                spaceSql.append(initSize);
                spaceSql.append("M");
            }
            spaceSql.append("ENGINE NDBCLUSTER;");
            try {
         
                dbUtil.executeUpdate(spaceSql.toString(), null);
            } catch (SQLException e) {
         
                e.printStackTrace();
            }
        }
    
        /**
         * 删除规则
         * A log file group cannot be dropped as long as any tablespaces use it.
         * A tablespace cannot be dropped as long as it contains any data files.
         * You cannot drop any data files from a tablespace as long as there remain any tables which are using the tablespace.
         * It is not possible to drop files created in association with a different tablespace other than the one with which the files were created.
         * @param dbUtil
         * @param spaceName
         * @param dataFileName
         * @param type "data"删除数据，"tablespace" :删除表空间 "loggroup":删除日志组
         */
        public static void dropSequence(DBUtil dbUtil, String spaceName, String dataFileName, String type){
         
            switch (type){
         
                case "data":
                    dropTableSpaceData(dbUtil, spaceName, dataFileName);
                    break;
                case "tablespace":
                    dropTableSpaceData(dbUtil, spaceName, dataFileName);
                    dropTableSpace(dbUtil,spaceName);
                    break;
                case "loggroup":
                    dropTableSpaceData(dbUtil, spaceName, dataFileName);
                    dropTableSpace(dbUtil,spaceName);
                    dropLogGroup(dbUtil);
                    break;
                default:
                    throw new IllegalArgumentException("参数错误");
            }
        }
    
        public static void CreateDocumentTable(String tableName, String spaceName, DBUtil dbUtil){
         
            checkArgument(spaceName);
            checkNullValue(tableName);
            StringBuilder executeSql = new StringBuilder();
            executeSql.append("CREATE TABLE ");
            executeSql.append(tableName);
            executeSql.append(" `doc` json DEFAULT NULL,");
            executeSql.append(" `_id` VARBINARY (32) GENERATED ALWAYS AS (json_unquote( json_extract (`doc`, _utf8mb4 '$._id'))) STORED NOT NULL,");
            executeSql.append("PRIMARY KEY (`_id`),UNIQUE KEY `trnk_dc` (`_id`) USING BTREE) TABLESPACE ");
            executeSql.append(spaceName);
            executeSql.append(" STORAGE DISK ENGINE NDBCLUSTER;");
            try {
         
                dbUtil.executeUpdate(executeSql.toString(), null);
            } catch (SQLException e) {
         
                e.printStackTrace();
            }
        }
    
        private static void dropLogGroup(DBUtil dbUtil){
         
            String dropSql = "DROP LOGFILE GROUP log_tk ENGINE = NDB;";
            try {
         
                dbUtil.executeUpdate(dropSql, null);
            } catch (SQLException e) {
         
                e.printStackTrace();
            }
        }
    
        private static void dropTableSpace(DBUtil dbUtil, String spaceName){
         
            checkArgument(spaceName);
            String dropSql = "DROP TABLESPACE "+spaceName+" ENGINE=NDB;";
            try {
         
                dbUtil.executeUpdate(dropSql, null);
            } catch (SQLException e) {
         
                e.printStackTrace();
            }
        }
    
        private static void dropTableSpaceData(DBUtil dbUtil, String spaceName, String dataFileName){
         
            checkArgument(spaceName);
            checkNullValue(dataFileName);
            String dropSql = "ALTER TABLESPACE "+spaceName+" DROP DATAFILE '"+dataFileName+"' ENGINE=NDB;";
            try {
         
                dbUtil.executeUpdate(dropSql, null);
            } catch (SQLException e) {
         
                e.printStackTrace();
            }
        }
    
        private static boolean checkArgument(String name){
         
            if (null != name && !"".equals(name) && !name.contains("."))
                return true;
            throw new IllegalArgumentException("请检查参数名称");
        }
    
        private static String createOrAlter(boolean isCreate){
         
            String type = "ALTER ";
            if (isCreate)
                type = "CREATE ";
            return type;
        }
    
        private static void checkNullValue(String value){
         
            if (null == value && "".trim().equals(value))
                throw new NullPointerException("参数不允许为空");
        }
    
    }

posted @ 2019-05-20 18:02 [龘\_曦][Link 1] 阅读( ...) 评论( ...) [编辑][Link 2] 收藏

[ndbcluster operator]: https://www.cnblogs.com/longa/p/10895632.html
[Link 1]: https://www.cnblogs.com/longa/
[Link 2]: https://i.cnblogs.com/EditPosts.aspx?postid=10895632