diff --git a/muyu-modules/muyu-system/src/main/java/com/muyu/system/a.txt b/muyu-modules/muyu-system/src/main/java/com/muyu/system/a.txt new file mode 100644 index 0000000..017b121 --- /dev/null +++ b/muyu-modules/muyu-system/src/main/java/com/muyu/system/a.txt @@ -0,0 +1,52 @@ + + package com.bwie.goods.service.impl; + +import com.bwie.common.domain.One; +import com.bwie.goods.mapper.GoodsMapper; +import com.bwie.goods.service.GoodsService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.sql.*; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +@Service +public class GoodsServiceImpl implements GoodsService { + @Autowired + private GoodsMapper mapper; + @Override + public List list() throws Exception { + HashMap> hm = new HashMap<>(); + Map map = new HashMap<>(); + List listString = new ArrayList<>(); + List listMap = new ArrayList<>(); + PreparedStatement pst = null; + Connection connection = null; + connection = DriverManager.getConnection("jdbc:mysql://129.211.23.219:3306/g63d15?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8","root","Qq4152637"); + List list = mapper.list(); + try { + pst = connection.prepareCall("select * from one"); + ResultSetMetaData rsd = pst.executeQuery().getMetaData(); + for (int i = 0; i < rsd.getColumnCount(); i++) { + System.out.println("java类型"+rsd.getColumnClassName(i+1)); + System.out.println("数据库类型"+rsd.getColumnTypeName(i+1)); + System.out.println("字段名称"+rsd.getColumnName(i+1)); + System.out.println("表名"+rsd.getTableName(i+1)); + System.out.println("数据库名"+rsd.getCatalogName(i+1)); + listString.add(rsd.getColumnName(i+1)); + listMap.add(rsd.getColumnClassName(i+1)); +// System.out.println(""+rsd.getSchemaName(i+1)); + } + } catch (SQLException e) { + throw new RuntimeException(e); + } + System.out.println(listString); + System.out.println(listMap); + for (One one : list) { + } + return list; + } +} diff --git a/muyu-modules/muyu-system/src/main/java/com/muyu/system/controller/AccreditController.java b/muyu-modules/muyu-system/src/main/java/com/muyu/system/controller/AccreditController.java index 5affa9b..a911b21 100644 --- a/muyu-modules/muyu-system/src/main/java/com/muyu/system/controller/AccreditController.java +++ b/muyu-modules/muyu-system/src/main/java/com/muyu/system/controller/AccreditController.java @@ -14,6 +14,7 @@ import lombok.extern.log4j.Log4j2; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; +import java.sql.SQLException; import java.util.List; @RestController @@ -32,7 +33,7 @@ public class AccreditController extends BaseController { * 获取表名 * @return */ - @GetMapping("tableNameList") + @PostMapping("tableNameList") public Result> tableNameList(){ List list = service.tableNameList(); return Result.success(list); @@ -49,7 +50,7 @@ public class AccreditController extends BaseController { } @GetMapping("listSqlJdbc") - public Result listSqlJdbc(){ + public Result listSqlJdbc() throws SQLException { return service.listSqlJdbc(); } diff --git a/muyu-modules/muyu-system/src/main/java/com/muyu/system/controller/DataAccessController.java b/muyu-modules/muyu-system/src/main/java/com/muyu/system/controller/DataAccessController.java index 1f2ec83..df6184e 100644 --- a/muyu-modules/muyu-system/src/main/java/com/muyu/system/controller/DataAccessController.java +++ b/muyu-modules/muyu-system/src/main/java/com/muyu/system/controller/DataAccessController.java @@ -1,5 +1,6 @@ package com.muyu.system.controller; +import java.sql.SQLException; import java.util.List; import javax.servlet.http.HttpServletResponse; import org.springframework.beans.factory.annotation.Autowired; @@ -75,8 +76,7 @@ public class DataAccessController extends BaseController @RequiresPermissions("system:access:add") @Log(title = "数据接入", businessType = BusinessType.INSERT) @PostMapping - public Result add(@RequestBody DataAccess dataAccess) - { + public Result add(@RequestBody DataAccess dataAccess) throws SQLException { return toAjax(dataAccessService.insertDataAccess(dataAccess)); } diff --git a/muyu-modules/muyu-system/src/main/java/com/muyu/system/mapper/AccreditMapper.java b/muyu-modules/muyu-system/src/main/java/com/muyu/system/mapper/AccreditMapper.java index e9bc43e..61a73b5 100644 --- a/muyu-modules/muyu-system/src/main/java/com/muyu/system/mapper/AccreditMapper.java +++ b/muyu-modules/muyu-system/src/main/java/com/muyu/system/mapper/AccreditMapper.java @@ -20,4 +20,7 @@ public interface AccreditMapper { int getNameSelTable(@Param("s") String s); void indexTableName(@Param("s") String s); + + void indexListStructure(@Param("columnClassName") String columnClassName, @Param("columnTypeName") String columnTypeName, @Param("columnName") String columnName, @Param("tableName") String tableName, @Param("catalogName") String catalogName); + } diff --git a/muyu-modules/muyu-system/src/main/java/com/muyu/system/service/AccreditService.java b/muyu-modules/muyu-system/src/main/java/com/muyu/system/service/AccreditService.java index f745619..932dee9 100644 --- a/muyu-modules/muyu-system/src/main/java/com/muyu/system/service/AccreditService.java +++ b/muyu-modules/muyu-system/src/main/java/com/muyu/system/service/AccreditService.java @@ -5,6 +5,7 @@ import com.muyu.system.domain.Library; import com.muyu.system.domain.TableName; import com.muyu.system.domain.vo.TableVo; +import java.sql.SQLException; import java.util.List; public interface AccreditService { @@ -14,5 +15,5 @@ public interface AccreditService { List tableNameList2(); - Result listSqlJdbc(); + Result listSqlJdbc() throws SQLException; } diff --git a/muyu-modules/muyu-system/src/main/java/com/muyu/system/service/IDataAccessService.java b/muyu-modules/muyu-system/src/main/java/com/muyu/system/service/IDataAccessService.java index 4c8ef93..971ac0d 100644 --- a/muyu-modules/muyu-system/src/main/java/com/muyu/system/service/IDataAccessService.java +++ b/muyu-modules/muyu-system/src/main/java/com/muyu/system/service/IDataAccessService.java @@ -1,19 +1,20 @@ package com.muyu.system.service; +import java.sql.SQLException; import java.util.List; import com.muyu.system.domain.DataAccess; /** * 数据接入Service接口 - * + * * @author muyu * @date 2024-04-21 */ -public interface IDataAccessService +public interface IDataAccessService { /** * 查询数据接入 - * + * * @param id 数据接入主键 * @return 数据接入 */ @@ -21,7 +22,7 @@ public interface IDataAccessService /** * 查询数据接入列表 - * + * * @param dataAccess 数据接入 * @return 数据接入集合 */ @@ -29,15 +30,15 @@ public interface IDataAccessService /** * 新增数据接入 - * + * * @param dataAccess 数据接入 * @return 结果 */ - public int insertDataAccess(DataAccess dataAccess); + public int insertDataAccess(DataAccess dataAccess) throws SQLException; /** * 修改数据接入 - * + * * @param dataAccess 数据接入 * @return 结果 */ @@ -45,7 +46,7 @@ public interface IDataAccessService /** * 批量删除数据接入 - * + * * @param ids 需要删除的数据接入主键集合 * @return 结果 */ @@ -53,7 +54,7 @@ public interface IDataAccessService /** * 删除数据接入信息 - * + * * @param id 数据接入主键 * @return 结果 */ diff --git a/muyu-modules/muyu-system/src/main/java/com/muyu/system/service/impl/AccreditServiceImpl.java b/muyu-modules/muyu-system/src/main/java/com/muyu/system/service/impl/AccreditServiceImpl.java index da3909e..5a6fefb 100644 --- a/muyu-modules/muyu-system/src/main/java/com/muyu/system/service/impl/AccreditServiceImpl.java +++ b/muyu-modules/muyu-system/src/main/java/com/muyu/system/service/impl/AccreditServiceImpl.java @@ -9,6 +9,7 @@ import com.muyu.system.service.AccreditService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import java.sql.*; import java.util.List; @Service @@ -43,8 +44,25 @@ public class AccreditServiceImpl implements AccreditService { } @Override - public Result listSqlJdbc() { - - return null; + public Result listSqlJdbc() throws SQLException { + PreparedStatement pst = null; + Connection conn = null; + String database = mapper.database(); + conn = DriverManager.getConnection("jdbc:mysql://129.211.23.219:3306/"+ database +"?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8","root","Qq4152637"); + try { + pst = conn.prepareCall("select * from admin"); + ResultSetMetaData rsd = pst.executeQuery().getMetaData(); + for (int i = 0; i < rsd.getColumnCount(); i++) { + System.out.println("java类型"+rsd.getColumnClassName(i+1)); + System.out.println("数据库类型"+rsd.getColumnTypeName(i+1)); + System.out.println("字段名称"+rsd.getColumnName(i+1)); + System.out.println("表名"+rsd.getTableName(i+1)); + System.out.println("数据库名"+rsd.getCatalogName(i+1)); + mapper.indexListStructure(rsd.getColumnClassName(i+1),rsd.getColumnTypeName(i+1),rsd.getColumnName(i+1),rsd.getTableName(i+1),rsd.getCatalogName(i+1)); + } + } catch (SQLException e) { + throw new RuntimeException(e); + } + return Result.success(""); } } diff --git a/muyu-modules/muyu-system/src/main/java/com/muyu/system/service/impl/DataAccessServiceImpl.java b/muyu-modules/muyu-system/src/main/java/com/muyu/system/service/impl/DataAccessServiceImpl.java index 564dab1..8a019c3 100644 --- a/muyu-modules/muyu-system/src/main/java/com/muyu/system/service/impl/DataAccessServiceImpl.java +++ b/muyu-modules/muyu-system/src/main/java/com/muyu/system/service/impl/DataAccessServiceImpl.java @@ -1,9 +1,12 @@ package com.muyu.system.service.impl; +import java.sql.SQLException; import java.util.List; import com.muyu.common.system.domain.SysDept; +import com.muyu.system.mapper.AccreditMapper; import com.muyu.system.mapper.SysDeptMapper; +import com.muyu.system.service.AccreditService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import com.muyu.system.mapper.DataAccessMapper; @@ -23,6 +26,8 @@ public class DataAccessServiceImpl implements IDataAccessService private DataAccessMapper dataAccessMapper; @Autowired private SysDeptMapper sysDeptMapper; + @Autowired + private AccreditService accreditService; /** * 查询数据接入 @@ -55,14 +60,14 @@ public class DataAccessServiceImpl implements IDataAccessService * @return 结果 */ @Override - public int insertDataAccess(DataAccess dataAccess) - { + public int insertDataAccess(DataAccess dataAccess) throws SQLException { int i = dataAccessMapper.insertDataAccess(dataAccess); List list = sysDeptMapper.listDeptList(); DataAccess dataAccess1 = dataAccessMapper.oneDataAccess(); for (SysDept sysDept : list) { dataAccessMapper.insertMiddle(sysDept.getDeptId(),dataAccess1.getId()); } + accreditService.listSqlJdbc(); return i; } diff --git a/muyu-modules/muyu-system/src/main/resources/mapper/system/AccreditMapper.xml b/muyu-modules/muyu-system/src/main/resources/mapper/system/AccreditMapper.xml index 58e2a59..53dcb2d 100644 --- a/muyu-modules/muyu-system/src/main/resources/mapper/system/AccreditMapper.xml +++ b/muyu-modules/muyu-system/src/main/resources/mapper/system/AccreditMapper.xml @@ -7,6 +7,10 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" insert into table_name (table_name) values (#{s}); + + insert into list_structure (column_lass_ame,column_type_name,column_name,table_name,catalog_name) + values (#{columnClassName},#{columnTypeName},#{columnName},#{tableName},#{catalogName}); +