需求來源

近期由於專案的圖片伺服器遷移導致大量寫死在資料庫中圖片路徑需要修改。

實現思路

通過百度瞭解到可以通過mysql的REPLACE函式來進行區域性替換資料內容，類似這樣的語句：
"UPDATE "+tableName+" SET "+column+" = REPLACE ( "+column + ",'"+oldValue+"','" +newValue+"')"。

版本演化一

我們瞭解基本實現思路，那麼進行簡單的資料替換就沒問題了。比如本來的資料是這樣http://www.oldImage.com/upload/image/1.jpg 需要改成http://www.newImage.com/upload/image/1.jpg

public class SQLUtils {
    /**
     * 資料來源
     */
    private final DruidDataSource ds;
    /**
     * 表和列集合
     */
    private Map<String, List<String>> table_column;
    /**
     * 日誌工具類
     */
    private Logger log = LoggerFactory.getLogger(SQLUtils.class);

    /**
     * 初始化資料來源
     *
     * @param
 
 db       資料庫
     * @param username 使用者名稱
     * @param password 密碼
     */
    public SQLUtils(String db, String username, String password) {
        ds = new DruidDataSource();
        ds.setUrl(db);
        ds.setUsername(username);
        ds.setPassword(password);
        initTableAndColumn(true
 
);
    }
}

然後我們再來定義一個替換資料的方法：

/**
     * 部分替換資料
     * @param tableName
     *      表名
     * @param column
     *      列名
     * @param oldValue
     *      舊值
     * @param newValue
     *      新值
     */
    public void update(String tableName,String column, String oldValue, String newValue) {
        Connection conn = null;
        try {
            conn = ds.getConnection();
            // 拼接sql
            String sql = "UPDATE " + tableName + " SET " + column + " = REPLACE ( " + column + ",'" + oldValue + "','" + newValue + "')";
            // 日誌輸出
            log.info("sql:{}", sql);
            int count = SqlExecutor.execute(conn, sql);
            log.info("影響行數：{}", count);
        } catch (SQLException e) {
            log.error(e.getMessage());
        } finally {
            DbUtil.close(conn);
        }
    }

接著來看看我們的入口函式：

    /**
     * 執行器
     *
     * @param args
     */
    public static void main(String[] args) {

        String db = "jdbc:mysql:///test";                                       // 資料來源
        String username = "root";                                               // 使用者名稱
        String password = "root";                                               // 密碼
        String tableName = "ad";                                                // 表名
        String column = "path";                                                 // 列名
        String oldValue = "oldImage.com";                                       // 舊值
        String newValue = "newImage.com";                                       // 新值
        SQLUtils sqlUtils = new SQLUtils(db, username, password);
        sqlUtils.batchExecute(tableName,column,oldValue, newValue);

    }

通過以上程式碼可以實現單條資料的修改。

版本演化二猜想

但是，如果資料庫中存在大量這樣的資料，比如說一個電商網站的商品圖片地址，這樣一條一條地修改資料恐怕你會瘋掉，如果圖片伺服器再次遷移恐怕你要跑路了。那麼我們如何批量修改呢？今天現在寫到這裡。。。。