Source/UBCS/ubcs-service/ubcs-ddl/src/main/java/com/vci/ubcs/ddl/processor/ddl/DdlMapperProcessor.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,157 @@
package com.vci.ubcs.ddl.processor.ddl;

import com.vci.ubcs.ddl.bo.DdlTableBO;
import com.vci.ubcs.ddl.bo.DdlTableInDataBaseBO;
import com.vci.ubcs.ddl.mapper.DdlMapper;
import com.vci.ubcs.starter.web.enumpck.VciFieldTypeEnum;

import java.util.List;

/**
 * Description:
 *
 * @author LiHang
 * @date 2023/4/24
 */
public abstract class DdlMapperProcessor implements DdlBehavior{

   public DdlMapperProcessor(DdlMapper mapper) {
      this.mapper = mapper;
   }

   private final DdlMapper mapper;

   abstract boolean support(String url);

   /**
    * ç»Ÿè®¡è¡¨æ ¼ä¸­æœ‰å¤šå°‘数据
    * @param tableName è¡¨æ ¼åç§°
    * @return æ•°æ®çš„总数
    */
   public int countAll(String tableName){
      return mapper.countAll(tableName);
   }

   /**
    * æ ¹æ®SQL语句创建视图
    * @param viewCreateSql
    * @return å½±å“è¡Œæ•°
    */
   public int createViewBySql( String viewCreateSql){
      return mapper.createViewBySql(viewCreateSql);
   }

   /**
    * æ ¹æ®sql语句插入数据
    * @param insertSql è¦æ‰§è¡Œçš„sql语句
    * @return å½±å“çš„行数
    */
   public int insertBySql(String insertSql){
      return mapper.insertBySql(insertSql);
   }

   /**
    * åˆ›å»ºæ•°æ®åº“表
    * @param tableName è¡¨æ ¼çš„名称
    * @param attributeSql å±žæ€§çš„sql
    * @return å½±å“çš„行数
    */
   public int createTableBySql(String tableName, String attributeSql){
      return mapper.createTableBySql(tableName,attributeSql);
   }

   /**
    * ä¸ºè¡¨æ ¼æ·»åŠ æ³¨é‡Šå†…容
    * @param tableName è¡¨æ ¼çš„名称
    * @param comment æ³¨é‡Šçš„内容
    * @return å—影响的行数
    */
   public int commentTable(String tableName,  String comment){
      return mapper.commentTable(tableName,comment);
   }

   /**
    * ä¸ºè¡¨æ ¼çš„列添加注释内容
    * @param tableName è¡¨æ ¼çš„名称
    * @param columnName åˆ—
    * @param comment æ³¨é‡Šçš„内容
    * @return å—影响的行数
    */
   public int commentColumnTable(String tableName,String columnName,  String comment){
      return mapper.commentColumnTable(tableName,columnName,comment);
   }

   /**
    * æ ¡éªŒæ•°æ®åº“表或者视图是否存在
    * @param tableName è¡¨æ ¼çš„名称，不区分大小写
    * @return å­˜åœ¨çš„个数
    */
   public int checkTableExist( String tableName){
      return mapper.checkTableExist(tableName);
   }

   /**
    * æŸ¥è¯¢è¡¨æ ¼çš„字段信息
    * @param tableName è¡¨æ ¼çš„名称
    * @return æ•°æ®åº“表的字段信息
    */
   public List<DdlTableInDataBaseBO> selectTableColumnInfo( String tableName){
      return mapper.selectTableColumnInfo(tableName);
   }

   /**
    * èŽ·å–所有的表格名称
    * @return è¡¨æ ¼åç§°
    */
   public List<String> selectAllTableName(){
      return mapper.selectAllTableName();
   }

   /**
    * æŸ¥è¯¢è¡¨æ ¼çš„中文名称
    * @param tableName è¡¨æ ¼åç§°
    * @return è¡¨æ ¼åç§°å’Œè¡¨æ ¼ä¸­æ–‡åç§°
    */
   public DdlTableBO selectTableComment(String tableName){
      return mapper.selectTableComment(tableName);
   }

   /**
    * å‘数据库表中添加单个字段
    * @param tableName è¡¨æ ¼çš„名称
    * @param attributeSql è¦æ·»åŠ çš„æ–°çš„sql
    * @return å½±å“çš„行数
    */
   public int addColumn2TableBySql(String tableName, String attributeSql){
      return mapper.addColumn2TableBySql(tableName,attributeSql);
   }

   /**
    * å•ä¸ªä¿®æ”¹æ•°æ®è¡¨çš„字段
    * @param tableName è¡¨æ ¼çš„名称
    * @param attributeSql å±žæ€§æ–°çš„sql
    * @return å½±å“çš„行数
    */
   public int modifyTableBySql( String tableName, String attributeSql){
      return mapper.modifyTableBySql(tableName,attributeSql);
   }

   /**
    * åˆ é™¤è¡¨æ ¼
    * @param tableName è¡¨æ ¼åç§°
    * @return å½±å“çš„行数
    */
   public int dropTable( String tableName){
      return mapper.dropTable(tableName);
   }

   /**
    * åˆ é™¤è¡¨æ ¼ä¸­çš„列
    * @param tableName è¡¨åç§°
    * @param columnName åˆ—名称
    * @return å—影响的行数
    */
   public int dropTableColumn(String tableName,String columnName){
      return mapper.dropTableColumn(tableName,columnName);
   }
}