# showdoc-data-fix

**Repository Path**: selfcloud/showdoc-data-fix

## Basic Information

- **Project Name**: showdoc-data-fix
- **Description**: Showdoc迁移图片数据，图片地址数据修复
- **Primary Language**: Java
- **License**: MulanPSL-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 1
- **Forks**: 1
- **Created**: 2021-03-04
- **Last Updated**: 2022-04-02

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# Showdoc 数据修复

## 核心代码



```java
public class ShowDocDataFix {

    @Test
    void contextLoads() throws SQLException, ClassNotFoundException {
        Class.forName("org.sqlite.JDBC");
        Connection connection = DriverManager.getConnection("jdbc:sqlite://D:\\Docker\\showdoc\\showdoc_data\\html\\Sqlite\\showdoc.db.php");
        System.out.println("Opened database successfully");
        Statement statement = connection.createStatement();

        String sql = "select page_id, page_content from page";
        ResultSet resultSet = statement.executeQuery(sql);

        Map<Integer, String> needFixDataMap = new ConcurrentHashMap<>();
        while (resultSet.next()) {
            int pageId = resultSet.getInt("page_id");
            String pageContent = resultSet.getString("page_content");
            if (pageContent == null) {
                continue;
            }

            if (pageContent.contains("http://172.16.9.55:4999/server/")) {
                pageContent = pageContent.replace("http://172.16.9.55:4999/server/", "http://172.16.6.66:4999/server/");

                needFixDataMap.put(pageId, pageContent);
            }
        }
        resultSet.close();

        // 修复数据
        needFixDataMap.forEach((pageId, pageContent) -> {
            try {
                PreparedStatement preparedStatement = connection.prepareStatement("update page set page_content = ? where page_id = ?");
                preparedStatement.setString(1, pageContent);
                preparedStatement.setInt(2, pageId);
                preparedStatement.executeUpdate();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        });

        statement.close();
        connection.close();
    }

}
```