| | |
| | | |
| | | import org.springblade.common.cache.DictCache; |
| | | import org.springblade.common.enums.DictEnum; |
| | | import org.springblade.common.utils.FtpUtil; |
| | | import org.springblade.common.utils.MysqlCenlint; |
| | | import org.springblade.core.cache.utils.CacheUtil; |
| | | import org.springblade.core.mp.support.Condition; |
| | | import org.springblade.core.mp.support.Query; |
| | |
| | | import org.springblade.modules.information.service.IInformationService; |
| | | import org.springblade.core.boot.ctrl.BladeController; |
| | | import springfox.documentation.annotations.ApiIgnore; |
| | | import java.sql.*; |
| | | import java.sql.DriverManager; //需要这个jar包 mysql-connector-java-5.1.49.jar |
| | | import java.util.List; |
| | | import java.util.ArrayList; |
| | | import java.util.Map; |
| | | import java.util.HashMap; |
| | | |
| | | import java.io.*; |
| | | import java.util.*; |
| | | |
| | | import static org.springblade.core.cache.constant.CacheConstant.SYS_CACHE; |
| | |
| | | return R.data(lists); |
| | | } |
| | | |
| | | // public static void main(String[] args) throws Exception { |
| | | // //ftp服务器IP地址 |
| | | // String ftpHost = "192.168.0.105"; |
| | | // //ftp服务器端口 |
| | | // int ftpPort = 21; |
| | | // //ftp服务器用户名 |
| | | // String ftpUserName = "yly"; |
| | | // //ftp服务器密码 |
| | | // String ftpPassword = "Yly@123"; |
| | | // //ftp服务器路径 |
| | | // String ftpPath = ""; |
| | | // //本地路径 |
| | | // String localPath = "D:\\anbao"; |
| | | // //文件名 |
| | | // String fileName = "sql.json"; |
| | | // FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName); |
| | | // String s = TestJson(); |
| | | // String sql = stringReplace(s); |
| | | // MysqlCenlint.inster(sql); |
| | | // MysqlCenlint.delete(); |
| | | // } |
| | | public static String stringReplace(String str) { |
| | | //去掉" "号 |
| | | String strs= str.replace("\"", ""); |
| | | return strs ; |
| | | |
| | | } |
| | | public static String TestJson(){ |
| | | File file = new File("D:\\anbao\\sql.json"); |
| | | StringBuilder localStrBulider = new StringBuilder(); |
| | | if(file.isFile() && file.exists()) { |
| | | try { |
| | | InputStreamReader inputStreamReader = new InputStreamReader(new FileInputStream(file), "utf-8"); |
| | | BufferedReader bufferReader = new BufferedReader(inputStreamReader); |
| | | String lineStr = null; |
| | | try { |
| | | while((lineStr = bufferReader.readLine()) != null) { |
| | | localStrBulider.append(lineStr); |
| | | } |
| | | bufferReader.close(); |
| | | inputStreamReader.close(); |
| | | } catch (IOException e) { |
| | | // TODO Auto-generated catch block |
| | | System.out.println("file read error!"); |
| | | e.printStackTrace(); |
| | | } |
| | | } catch (UnsupportedEncodingException e) { |
| | | // TODO Auto-generated catch block |
| | | System.out.println("file catch unsupported encoding!"); |
| | | e.printStackTrace(); |
| | | } catch (FileNotFoundException e) { |
| | | // TODO Auto-generated catch block |
| | | System.out.println("file not found!"); |
| | | e.printStackTrace(); |
| | | } |
| | | }else { |
| | | System.out.println("file is not a file or file is not existing!"); |
| | | } |
| | | return localStrBulider.toString(); |
| | | } |
| | | |
| | | } |