java如何利用json文件來實(shí)現(xiàn)數(shù)據(jù)庫數(shù)據(jù)的導(dǎo)入導(dǎo)出

這篇文章將為大家詳細(xì)講解有關(guān)java如何利用json文件來實(shí)現(xiàn)數(shù)據(jù)庫數(shù)據(jù)的導(dǎo)入導(dǎo)出，小編覺得挺實(shí)用的，因此分享給大家做個參考，希望大家閱讀完這篇文章后可以有所收獲。

背景：

工作中我們可能會遇到需要將某個環(huán)境中的某些數(shù)據(jù)快速的移動到另一個環(huán)境的情況，此時我們就可以通過導(dǎo)入導(dǎo)出json文件的方式實(shí)現(xiàn)。

舉例：

我們將這個環(huán)境的數(shù)據(jù)庫中用戶信息導(dǎo)出為一份json格式文件，再直接將json文件復(fù)制到另一個環(huán)境導(dǎo)入到數(shù)據(jù)庫，這樣可以達(dá)到我們的目的。

下面我將使用springboot搭建用戶數(shù)據(jù)信息的導(dǎo)入導(dǎo)出案例，實(shí)現(xiàn)了單用戶和多用戶數(shù)據(jù)庫信息的導(dǎo)入導(dǎo)出功能。認(rèn)真看完這篇文章，你一定能掌握導(dǎo)入導(dǎo)出json文件的核心

準(zhǔn)備工作

需要maven依賴坐標(biāo)：

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-thymeleaf</artifactId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.1.0</version>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.18</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.29</version>
        </dependency>
        <dependency>
            <groupId>org.codehaus.jackson</groupId>
            <artifactId>jackson-mapper-asl</artifactId>
            <version>1.9.13</version>
        </dependency>

數(shù)據(jù)庫中的用戶信息：

這些字段信息與Java中的UserEntity實(shí)體類一一對應(yīng)

功能實(shí)現(xiàn)

準(zhǔn)備好依賴和數(shù)據(jù)庫信息之后，開始搭建用戶導(dǎo)入導(dǎo)出具體框架：

導(dǎo)入導(dǎo)出單用戶、多用戶功能實(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)入用戶
    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)為字符串類型
            File file = new File("/"+ fileName);
            //將MultipartFile類型轉(zhuǎn)換為File類型
            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í)體類
                JSONObject jsonObject = JSONObject.parseObject(jsonString);

                UserEntity userEntity = JSONObject.toJavaObject(jsonObject, UserEntity.class);

                userEntity.setId(null);
                userEntity.setToken(UUID.randomUUID().toString());
                //調(diào)用創(chuàng)建用戶的接口
                userService.addUser(userEntity);

            } else {
                resultModel.setStatusCode(0);
                resultModel.setStatusMes("請上傳正確格式的.json或.txt文件！");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return resultModel;
    }
    //批量導(dǎo)入用戶
    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)為字符串類型
            File file = new File("/"+ fileName);
            //將MultipartFile類型轉(zhuǎn)換為File類型
            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í)體類
                JSONObject jsonObject = JSONObject.parseObject(jsonString);

                UserEntityList userEntityList = JSONObject.toJavaObject(jsonObject, UserEntityList.class);

                List<UserEntity> userEntities = userEntityList.getUserEntities();
                for (UserEntity userEntity : userEntities) {
                    userEntity.setId(null);
                    userEntity.setToken(UUID.randomUUID().toString());
                    //調(diào)用創(chuàng)建用戶的接口
                    userService.addUser(userEntity);
                }
            } else {
                resultModel.setStatusCode(0);
                resultModel.setStatusMes("請上傳正確格式的.json或.txt文件！");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return resultModel;
    }
    //導(dǎo)出某個用戶
    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沒有對應(yīng)的用戶");
            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);
                // 設(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)建輸出對象
                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)閉輸出流，不然會繼續(xù)寫入返回實(shí)體模型
                return resultModel;
            } catch (Exception e) {
                resultModel.setStatusCode(0);
                resultModel.setStatusMes(e.getMessage());
                e.printStackTrace();
                return resultModel;
            }
        }
    }
    //導(dǎo)出所有用戶
    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沒有對應(yīng)的用戶");
            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);
                // 設(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)建輸出對象
                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)閉輸出流，不然會繼續(xù)寫入返回實(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、啟動項目，瀏覽器輸入訪問 http://localhost:8888/export/users 導(dǎo)出所有已有用戶json文件

2、打開json文件查看格式是否正確

3、瀏覽器輸入訪問 http://localhost:8888/ 批量導(dǎo)入用戶

導(dǎo)入 users.json 文件

輸入地址，點(diǎn)擊提交

查看數(shù)據(jù)庫，發(fā)現(xiàn)增加的兩條測試用戶1,2成功！

導(dǎo)入導(dǎo)出單個用戶這里就不測試了，更加簡單，其他的關(guān)于springboot配置文件和實(shí)體類對應(yīng)數(shù)據(jù)庫信息也不詳細(xì)說明了。

關(guān)于java如何利用json文件來實(shí)現(xiàn)數(shù)據(jù)庫數(shù)據(jù)的導(dǎo)入導(dǎo)出就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，可以學(xué)到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。