代码生成支持同步数据库

RuoYi

2020-09-18 9e38c7de2e51613e248926b4a29616959853682d

代码生成支持同步数据库

 ruoyi-generator/src/main/java/com/ruoyi/generator/controller/GenController.java

@@ -165,13 +165,25 @@
    @PreAuthorize("@ss.hasPermi('tool:gen:code')")

    @Log(title = "代码生成", businessType = BusinessType.GENCODE)

    @GetMapping("/genCode/{tableName}")

    public AjaxResult genCode(HttpServletResponse response, @PathVariable("tableName") String tableName)

    public AjaxResult genCode(@PathVariable("tableName") String tableName)

    {

        genTableService.generatorCode(tableName);

        return AjaxResult.success();

    }



    /**

     * 同步数据库

     */

    @PreAuthorize("@ss.hasPermi('tool:gen:edit')")

    @Log(title = "代码生成", businessType = BusinessType.UPDATE)

    @GetMapping("/synchDb/{tableName}")

    public AjaxResult synchDb(@PathVariable("tableName") String tableName)

    {

        genTableService.synchDb(tableName);

        return AjaxResult.success();

    }



    /**

     * 批量生成代码

     */

    @PreAuthorize("@ss.hasPermi('tool:gen:code')")


 ruoyi-generator/src/main/java/com/ruoyi/generator/mapper/GenTableColumnMapper.java

@@ -17,7 +17,7 @@
     * @return 列信息

     */

    public List<GenTableColumn> selectDbTableColumnsByName(String tableName);

    


    /**

     * 查询业务字段列表

     * 

@@ -43,6 +43,14 @@
    public int updateGenTableColumn(GenTableColumn genTableColumn);



    /**

     * 删除业务字段

     * 
     * @param genTableColumns 列数据

     * @return 结果

     */

    public int deleteGenTableColumns(List<GenTableColumn> genTableColumns);



    /**

     * 批量删除业务字段

     * 

     * @param ids 需要删除的数据ID


 ruoyi-generator/src/main/java/com/ruoyi/generator/service/GenTableServiceImpl.java

@@ -7,6 +7,7 @@
import java.util.LinkedHashMap;

import java.util.List;

import java.util.Map;

import java.util.stream.Collectors;

import java.util.zip.ZipEntry;

import java.util.zip.ZipOutputStream;

import org.apache.commons.io.IOUtils;

@@ -224,7 +225,6 @@
     * 生成代码（自定义路径）

     * 

     * @param tableName 表名称

     * @return 数据

     */

    @Override

    public void generatorCode(String tableName)

@@ -263,6 +263,37 @@
    }



    /**

     * 同步数据库

     * 
     * @param tableName 表名称

     */

    @Override

    @Transactional

    public void synchDb(String tableName)

    {

        GenTable table = genTableMapper.selectGenTableByName(tableName);

        List<GenTableColumn> tableColumns = table.getColumns();

        List<String> tableColumnNames = tableColumns.stream().map(GenTableColumn::getColumnName).collect(Collectors.toList());



        List<GenTableColumn> dbTableColumns = genTableColumnMapper.selectDbTableColumnsByName(tableName);

        List<String> dbTableColumnNames = dbTableColumns.stream().map(GenTableColumn::getColumnName).collect(Collectors.toList());



        dbTableColumns.forEach(column -> {

            if (!tableColumnNames.contains(column.getColumnName()))

            {

                GenUtils.initColumnField(column, table);

                genTableColumnMapper.insertGenTableColumn(column);

            }

        });



        List<GenTableColumn> delColumns = tableColumns.stream().filter(column -> !dbTableColumnNames.contains(column.getColumnName())).collect(Collectors.toList());

        if (StringUtils.isNotEmpty(delColumns))

        {

            genTableColumnMapper.deleteGenTableColumns(delColumns);

        }

    }



    /**

     * 批量生成代码（下载方式）

     * 

     * @param tableNames 表数组


 ruoyi-generator/src/main/java/com/ruoyi/generator/service/IGenTableService.java

@@ -91,6 +91,13 @@
    public void generatorCode(String tableName);



    /**

     * 同步数据库

     * 
     * @param tableName 表名称

     */

    public void synchDb(String tableName);



    /**

     * 批量生成代码（下载方式）

     * 

     * @param tableNames 表数组


 ruoyi-generator/src/main/resources/mapper/generator/GenTableColumnMapper.xml

@@ -117,4 +117,10 @@
        </foreach>

    </delete>

    

    <delete id="deleteGenTableColumns">

        delete from gen_table_column where column_id in 
        <foreach collection="list" item="item" open="(" separator="," close=")">

            #{item.columnId}

        </foreach>

    </delete>

</mapper>

 ruoyi-generator/src/main/resources/mapper/generator/GenTableMapper.xml

@@ -186,4 +186,4 @@
        </foreach>

    </delete>



</mapper> 
</mapper>

 ruoyi-ui/src/api/tool/gen.js

@@ -67,3 +67,10 @@
  })

}



// 同步数据库

export function synchDb(tableName) {

  return request({

    url: '/tool/gen/synchDb/' + tableName,

    method: 'get'

  })

}


 ruoyi-ui/src/views/tool/gen/index.vue

@@ -135,6 +135,13 @@
          <el-button

            type="text"

            size="small"

            icon="el-icon-refresh"

            @click="handleSynchDb(scope.row)"

            v-hasPermi="['tool:gen:edit']"

          >同步</el-button>

          <el-button

            type="text"

            size="small"

            icon="el-icon-download"

            @click="handleGenTable(scope.row)"

            v-hasPermi="['tool:gen:code']"

@@ -167,7 +174,7 @@
</template>



<script>

import { listTable, previewTable, delTable, genCode } from "@/api/tool/gen";

import { listTable, previewTable, delTable, genCode, synchDb } from "@/api/tool/gen";

import importTable from "./importTable";

import { downLoadZip } from "@/utils/zipdownload";

export default {

@@ -252,6 +259,19 @@
        downLoadZip("/tool/gen/batchGenCode?tables=" + tableNames, "ruoyi");

      }

    },

    /** 同步数据库操作 */

    handleSynchDb(row) {

      const tableName = row.tableName;

      this.$confirm('确认要强制同步"' + tableName + '"表结构吗？', "警告", {

        confirmButtonText: "确定",

        cancelButtonText: "取消",

        type: "warning"

      }).then(function() {

          return synchDb(tableName);

      }).then(() => {

          this.msgSuccess("同步成功");

      }).catch(function() {});

    },

    /** 打开导入表弹窗 */

    openImportTable() {

      this.$refs.import.show();