背景：
工作中我們可能會遇到需要將某個環(huán)境中的某些數據快速的移動到另一個環(huán)境的情況，此時我們就可以通過導入導出json文件的方式實現。
（學習視頻分享：java課程）
舉例：
我們將這個環(huán)境的數據庫中用戶信息導出為一份json格式文件，再直接將json文件復制到另一個環(huán)境導入到數據庫，這樣可以達到我們的目的。
下面我將使用springboot搭建用戶數據信息的導入導出案例，實現了單用戶和多用戶數據庫信息的導入導出功能。認真看完這篇文章，你一定能掌握導入導出json文件的核心
準備工作
需要maven依賴坐標：
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
數據庫中的用戶信息：
這些字段信息與Java中的UserEntity實體類一一對應
功能實現
準備好依賴和數據庫信息之后，開始搭建用戶導入導出具體框架：
導入導出單用戶、多用戶功能實現 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 {
//導入用戶
public static ResultModel importUser(MultipartFile multipartFile, UserService userService) {
ResultModel resultModel = new ResultModel();
try {
// 獲取原始名字
String fileName = multipartFile.getOriginalFilename();
// 獲取后綴名
String suffixName = fileName.substring(fileName.lastIndexOf("."));
//先將.json文件轉為字符串類型
File file = new File("/"+ fileName);
//將MultipartFile類型轉換為File類型
FileUtils.copyInputStreamToFile(multipartFile.getInputStream(),file);
String jsonString = FileUtils.readFileToString(file, "UTF-8");
//如果是json或者txt文件
if (".json".equals(suffixName) || ".txt".equals(suffixName)) {
//再將json字符串轉為實體類
JSONObject jsonObject = JSONObject.parseObject(jsonString);
UserEntity userEntity = JSONObject.toJavaObject(jsonObject, UserEntity.class);
userEntity.setId(null);
userEntity.setToken(UUID.randomUUID().toString());
//調用創(chuàng)建用戶的接口
userService.addUser(userEntity);
} else {
resultModel.setStatusCode(0);
resultModel.setStatusMes("請上傳正確格式的.json或.txt文件！");
}
} catch (Exception e) {
e.printStackTrace();
}
return resultModel;
}
//批量導入用戶
public static ResultModel importUsers(MultipartFile multipartFile, UserService userService) {
ResultModel resultModel = new ResultModel();
try {
// 獲取原始名字
String fileName = multipartFile.getOriginalFilename();
// 獲取后綴名
String suffixName = fileName.substring(fileName.lastIndexOf("."));
//先將.json文件轉為字符串類型
File file = new File("/"+ fileName);
//將MultipartFile類型轉換為File類型
FileUtils.copyInputStreamToFile(multipartFile.getInputStream(),file);
String jsonString = FileUtils.readFileToString(file, "UTF-8");
//如果是json或者txt文件
if (".json".equals(suffixName) || ".txt".equals(suffixName)) {
//再將json字符串轉為實體類
JSONObject jsonObject = JSONObject.parseObject(jsonString);
UserEntityList userEntityList = JSONObject.toJavaObject(jsonObject, UserEntityList.class);
List userEntities = userEntityList.getUserEntities();
for (UserEntity userEntity : userEntities) {
userEntity.setId(null);
userEntity.setToken(UUID.randomUUID().toString());
//調用創(chuàng)建用戶的接口
userService.addUser(userEntity);
}
} else {
resultModel.setStatusCode(0);
resultModel.setStatusMes("請上傳正確格式的.json或.txt文件！");
}
} catch (Exception e) {
e.printStackTrace();
}
return resultModel;
}
//導出某個用戶
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("此用戶id沒有對應的用戶");
return resultModel;
}else {
try {
String jsonString = objectMapper.writeValueAsString(userEntity);
// 拼接文件完整路徑// 生成json格式文件
String fullPath = "/" + fileName;
// 保證創(chuàng)建一個新文件
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);
// 將格式化后的字符串寫入文件
Writer write = new OutputStreamWriter(new FileOutputStream(file), "UTF-8");
write.write(jsonString);
write.flush();
write.close();
FileInputStream fis = new FileInputStream(file);
// 設置相關格式
response.setContentType("application/force-download");
// 設置下載后的文件名以及header
response.setHeader("Content-Disposition", "attachment;filename="
.concat(String.valueOf(URLEncoder.encode(fileName, "UTF-8"))));
response.setCharacterEncoding("utf-8");
// 創(chuàng)建輸出對象
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(); //一定要記得關閉輸出流，不然會繼續(xù)寫入返回實體模型
return resultModel;
} catch (Exception e) {
resultModel.setStatusCode(0);
resultModel.setStatusMes(e.getMessage());
e.printStackTrace();
return resultModel;
}
}
}
//導出所有用戶
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("此用戶id沒有對應的用戶");
return resultModel;
}else {
try {
String jsonString = objectMapper.writeValueAsString(userEntityList);
// 拼接文件完整路徑// 生成json格式文件
String fullPath = "/" + fileName;
// 保證創(chuàng)建一個新文件
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);
// 將格式化后的字符串寫入文件
Writer write = new OutputStreamWriter(new FileOutputStream(file), "UTF-8");
write.write(jsonString);
write.flush();
write.close();
FileInputStream fis = new FileInputStream(file);
// 設置相關格式
response.setContentType("application/force-download");
// 設置下載后的文件名以及header
response.setHeader("Content-Disposition", "attachment;filename="
.concat(String.valueOf(URLEncoder.encode(fileName, "UTF-8"))));
response.setCharacterEncoding("utf-8");
// 創(chuàng)建輸出對象
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(); //一定要記得關閉輸出流，不然會繼續(xù)寫入返回實體模型
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、啟動項目，瀏覽器輸入訪問 http://localhost:8888/export/users 導出所有已有用戶json文件
2、打開json文件查看格式是否正確
3、瀏覽器輸入訪問 http://localhost:8888/ 批量導入用戶
導入 users.json 文件
輸入地址，點擊提交
查看數據庫，發(fā)現增加的兩條測試用戶1,2成功！
導入導出單個用戶這里就不測試了，更加簡單，其他的關于springboot配置文件和實體類對應數據庫信息也不詳細說明了。
相關推薦：java入門
新聞名稱：java利用json文件來實現數據庫數據的導入導出
鏈接分享：http://weahome.cn/article/cjdcpd.html
