這篇文章將為大家詳細(xì)講解有關(guān)java如何利用json文件來(lái)實(shí)現(xiàn)數(shù)據(jù)庫(kù)數(shù)據(jù)的導(dǎo)入導(dǎo)出,小編覺(jué)得挺實(shí)用的,因此分享給大家做個(gè)參考,希望大家閱讀完這篇文章后可以有所收獲。
成都創(chuàng)新互聯(lián)是一家集網(wǎng)站建設(shè),塔城企業(yè)網(wǎng)站建設(shè),塔城品牌網(wǎng)站建設(shè),網(wǎng)站定制,塔城網(wǎng)站建設(shè)報(bào)價(jià),網(wǎng)絡(luò)營(yíng)銷(xiāo),網(wǎng)絡(luò)優(yōu)化,塔城網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè),幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強(qiáng)企業(yè)競(jìng)爭(zhēng)力??沙浞譂M足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時(shí)我們時(shí)刻保持專(zhuān)業(yè)、時(shí)尚、前沿,時(shí)刻以成就客戶(hù)成長(zhǎng)自我,堅(jiān)持不斷學(xué)習(xí)、思考、沉淀、凈化自己,讓我們?yōu)楦嗟钠髽I(yè)打造出實(shí)用型網(wǎng)站。
背景:
工作中我們可能會(huì)遇到需要將某個(gè)環(huán)境中的某些數(shù)據(jù)快速的移動(dòng)到另一個(gè)環(huán)境的情況,此時(shí)我們就可以通過(guò)導(dǎo)入導(dǎo)出json文件的方式實(shí)現(xiàn)。
舉例:
我們將這個(gè)環(huán)境的數(shù)據(jù)庫(kù)中用戶(hù)信息導(dǎo)出為一份json格式文件,再直接將json文件復(fù)制到另一個(gè)環(huán)境導(dǎo)入到數(shù)據(jù)庫(kù),這樣可以達(dá)到我們的目的。
下面我將使用springboot搭建用戶(hù)數(shù)據(jù)信息的導(dǎo)入導(dǎo)出案例,實(shí)現(xiàn)了單用戶(hù)和多用戶(hù)數(shù)據(jù)庫(kù)信息的導(dǎo)入導(dǎo)出功能。認(rèn)真看完這篇文章,你一定能掌握導(dǎo)入導(dǎo)出json文件的核心
準(zhǔn)備工作
需要maven依賴(lài)坐標(biāo):
org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boot-starter-actuator org.springframework.boot spring-boot-starter-thymeleaf org.projectlombok lombok true org.mybatis.spring.boot mybatis-spring-boot-starter 2.1.0 MySQL mysql-connector-java 8.0.18 org.springframework.boot spring-boot-starter-jdbc com.alibaba fastjson 1.2.29 org.codehaus.jackson jackson-mapper-asl 1.9.13
數(shù)據(jù)庫(kù)中的用戶(hù)信息:
這些字段信息與Java中的UserEntity實(shí)體類(lèi)一一對(duì)應(yīng)
功能實(shí)現(xiàn)
準(zhǔn)備好依賴(lài)和數(shù)據(jù)庫(kù)信息之后,開(kāi)始搭建用戶(hù)導(dǎo)入導(dǎo)出具體框架:
導(dǎo)入導(dǎo)出單用戶(hù)、多用戶(hù)功能實(shí)現(xiàn) UserUtil
package com.leige.test.util; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.serializer.SerializerFeature; import com.leige.test.entity.UserEntity; import com.leige.test.entity.UserEntityList; import com.leige.test.model.ResultModel; import com.leige.test.service.UserService; import org.apache.commons.io.FileUtils; import org.codehaus.jackson.map.ObjectMapper; import org.springframework.util.ObjectUtils; import org.springframework.web.multipart.MultipartFile; import javax.servlet.http.HttpServletResponse; import java.io.*; import java.net.URLEncoder; import java.util.List; import java.util.UUID; public class UserUtil { //導(dǎo)入用戶(hù) public static ResultModel importUser(MultipartFile multipartFile, UserService userService) { ResultModel resultModel = new ResultModel(); try { // 獲取原始名字 String fileName = multipartFile.getOriginalFilename(); // 獲取后綴名 String suffixName = fileName.substring(fileName.lastIndexOf(".")); //先將.json文件轉(zhuǎn)為字符串類(lèi)型 File file = new File("/"+ fileName); //將MultipartFile類(lèi)型轉(zhuǎn)換為File類(lèi)型 FileUtils.copyInputStreamToFile(multipartFile.getInputStream(),file); String jsonString = FileUtils.readFileToString(file, "UTF-8"); //如果是json或者txt文件 if (".json".equals(suffixName) || ".txt".equals(suffixName)) { //再將json字符串轉(zhuǎn)為實(shí)體類(lèi) JSONObject jsonObject = JSONObject.parseObject(jsonString); UserEntity userEntity = JSONObject.toJavaObject(jsonObject, UserEntity.class); userEntity.setId(null); userEntity.setToken(UUID.randomUUID().toString()); //調(diào)用創(chuàng)建用戶(hù)的接口 userService.addUser(userEntity); } else { resultModel.setStatusCode(0); resultModel.setStatusMes("請(qǐng)上傳正確格式的.json或.txt文件!"); } } catch (Exception e) { e.printStackTrace(); } return resultModel; } //批量導(dǎo)入用戶(hù) public static ResultModel importUsers(MultipartFile multipartFile, UserService userService) { ResultModel resultModel = new ResultModel(); try { // 獲取原始名字 String fileName = multipartFile.getOriginalFilename(); // 獲取后綴名 String suffixName = fileName.substring(fileName.lastIndexOf(".")); //先將.json文件轉(zhuǎn)為字符串類(lèi)型 File file = new File("/"+ fileName); //將MultipartFile類(lèi)型轉(zhuǎn)換為File類(lèi)型 FileUtils.copyInputStreamToFile(multipartFile.getInputStream(),file); String jsonString = FileUtils.readFileToString(file, "UTF-8"); //如果是json或者txt文件 if (".json".equals(suffixName) || ".txt".equals(suffixName)) { //再將json字符串轉(zhuǎn)為實(shí)體類(lèi) JSONObject jsonObject = JSONObject.parseObject(jsonString); UserEntityList userEntityList = JSONObject.toJavaObject(jsonObject, UserEntityList.class); ListuserEntities = userEntityList.getUserEntities(); for (UserEntity userEntity : userEntities) { userEntity.setId(null); userEntity.setToken(UUID.randomUUID().toString()); //調(diào)用創(chuàng)建用戶(hù)的接口 userService.addUser(userEntity); } } else { resultModel.setStatusCode(0); resultModel.setStatusMes("請(qǐng)上傳正確格式的.json或.txt文件!"); } } catch (Exception e) { e.printStackTrace(); } return resultModel; } //導(dǎo)出某個(gè)用戶(hù) public static ResultModel exportUser(HttpServletResponse response, UserEntity userEntity, String fileName){ ResultModel resultModel = new ResultModel(); ObjectMapper objectMapper = new ObjectMapper(); if (ObjectUtils.isEmpty(userEntity)){ resultModel.setStatusCode(0); resultModel.setStatusMes("此用戶(hù)id沒(méi)有對(duì)應(yīng)的用戶(hù)"); return resultModel; }else { try { String jsonString = objectMapper.writeValueAsString(userEntity); // 拼接文件完整路徑// 生成json格式文件 String fullPath = "/" + fileName; // 保證創(chuàng)建一個(gè)新文件 File file = new File(fullPath); if (!file.getParentFile().exists()) { // 如果父目錄不存在,創(chuàng)建父目錄 file.getParentFile().mkdirs(); } if (file.exists()) { // 如果已存在,刪除舊文件 file.delete(); } file.createNewFile();//創(chuàng)建新文件 //將字符串格式化為json格式 jsonString = jsonFormat(jsonString); // 將格式化后的字符串寫(xiě)入文件 Writer write = new OutputStreamWriter(new FileOutputStream(file), "UTF-8"); write.write(jsonString); write.flush(); write.close(); FileInputStream fis = new FileInputStream(file); // 設(shè)置相關(guān)格式 response.setContentType("application/force-download"); // 設(shè)置下載后的文件名以及header response.setHeader("Content-Disposition", "attachment;filename=" .concat(String.valueOf(URLEncoder.encode(fileName, "UTF-8")))); response.setCharacterEncoding("utf-8"); // 創(chuàng)建輸出對(duì)象 OutputStream os = response.getOutputStream(); // 常規(guī)操作 byte[] buf = new byte[1024]; int len = 0; while((len = fis.read(buf)) != -1) { os.write(buf, 0, len); } fis.close(); os.close(); //一定要記得關(guān)閉輸出流,不然會(huì)繼續(xù)寫(xiě)入返回實(shí)體模型 return resultModel; } catch (Exception e) { resultModel.setStatusCode(0); resultModel.setStatusMes(e.getMessage()); e.printStackTrace(); return resultModel; } } } //導(dǎo)出所有用戶(hù) public static ResultModel exportAllUser(HttpServletResponse response, UserEntityList userEntityList, String fileName){ ResultModel resultModel = new ResultModel(); ObjectMapper objectMapper = new ObjectMapper(); if (ObjectUtils.isEmpty(userEntityList)){ resultModel.setStatusCode(0); resultModel.setStatusMes("此用戶(hù)id沒(méi)有對(duì)應(yīng)的用戶(hù)"); return resultModel; }else { try { String jsonString = objectMapper.writeValueAsString(userEntityList); // 拼接文件完整路徑// 生成json格式文件 String fullPath = "/" + fileName; // 保證創(chuàng)建一個(gè)新文件 File file = new File(fullPath); if (!file.getParentFile().exists()) { // 如果父目錄不存在,創(chuàng)建父目錄 file.getParentFile().mkdirs(); } if (file.exists()) { // 如果已存在,刪除舊文件 file.delete(); } file.createNewFile();//創(chuàng)建新文件 //將字符串格式化為json格式 jsonString = jsonFormat(jsonString); // 將格式化后的字符串寫(xiě)入文件 Writer write = new OutputStreamWriter(new FileOutputStream(file), "UTF-8"); write.write(jsonString); write.flush(); write.close(); FileInputStream fis = new FileInputStream(file); // 設(shè)置相關(guān)格式 response.setContentType("application/force-download"); // 設(shè)置下載后的文件名以及header response.setHeader("Content-Disposition", "attachment;filename=" .concat(String.valueOf(URLEncoder.encode(fileName, "UTF-8")))); response.setCharacterEncoding("utf-8"); // 創(chuàng)建輸出對(duì)象 OutputStream os = response.getOutputStream(); // 常規(guī)操作 byte[] buf = new byte[1024]; int len = 0; while((len = fis.read(buf)) != -1) { os.write(buf, 0, len); } fis.close(); os.close(); //一定要記得關(guān)閉輸出流,不然會(huì)繼續(xù)寫(xiě)入返回實(shí)體模型 return resultModel; } catch (Exception e) { resultModel.setStatusCode(0); resultModel.setStatusMes(e.getMessage()); e.printStackTrace(); return resultModel; } } } //將字符串格式化為json格式的字符串 public static String jsonFormat(String jsonString) { JSONObject object= JSONObject.parseObject(jsonString); jsonString = JSON.toJSONString(object, SerializerFeature.PrettyFormat, SerializerFeature.WriteMapNullValue, SerializerFeature.WriteDateUseDateFormat); return jsonString; } }
1、啟動(dòng)項(xiàng)目,瀏覽器輸入訪問(wèn) http://localhost:8888/export/users 導(dǎo)出所有已有用戶(hù)json文件
2、打開(kāi)json文件查看格式是否正確
3、瀏覽器輸入訪問(wèn) http://localhost:8888/ 批量導(dǎo)入用戶(hù)
導(dǎo)入 users.json 文件
輸入地址,點(diǎn)擊提交
查看數(shù)據(jù)庫(kù),發(fā)現(xiàn)增加的兩條測(cè)試用戶(hù)1,2成功!
導(dǎo)入導(dǎo)出單個(gè)用戶(hù)這里就不測(cè)試了,更加簡(jiǎn)單,其他的關(guān)于springboot配置文件和實(shí)體類(lèi)對(duì)應(yīng)數(shù)據(jù)庫(kù)信息也不詳細(xì)說(shuō)明了。
關(guān)于java如何利用json文件來(lái)實(shí)現(xiàn)數(shù)據(jù)庫(kù)數(shù)據(jù)的導(dǎo)入導(dǎo)出就分享到這里了,希望以上內(nèi)容可以對(duì)大家有一定的幫助,可以學(xué)到更多知識(shí)。如果覺(jué)得文章不錯(cuò),可以把它分享出去讓更多的人看到。