2. 程式人生 > >Java實現簡單的資料遷移，從單庫單表到單庫單表（2）

Java實現簡單的資料遷移，從單庫單表到單庫單表（2）

阿新 • • 發佈：2018-12-12

這個文章是對我上一篇文章Java實現簡單的資料遷移，從單庫單表到單庫單表的簡單擴充套件因為我上一篇文章那種方法只能把資料進行簡單的遷移，但是這裡我需要對資料庫的內容進行重新的編排，所以很顯然，我上一篇文章的寫法是沒法完成我的需求的。 重申一下需求： 從一張資料表：物品分類資料資源表和一張關係表：物品分類關係表將這兩張表的內容整理到一張表中：整理好的表，目的是為了把前兩張表裡面的第一層的物品第二層的物品，第三層的物品整理出來，並且寫好歸屬。 （姑且算是遷移吧） 不知道看管能不能有耐心看完他，總之原理很簡單，

  1. 從一個數據庫中把資料讀取出來。
  2. 然後在連結上另外一個數據庫的表進行insert寫入。

當然，我想使用MySQL的儲存過程應該也是可以完成這個需求的，但是我目前還不會，之後會整理之後放入這一系列的文章中。 （程式碼寫的很垃圾，將就著看吧。）

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

public class DataCategorySinze {

	static ResultSet rsOne;
	private  static List<ResultSet> list = new ArrayList<ResultSet>();
	
	public static void main(String[] args) {
		int count = 0;
		try {
			//首先寫入第一層
//			DataCategorySinze.getDeepZeroS();
			//接著寫入第二層
//			DataCategorySinze.getDeepZero(count);
			//最後寫入第三層
			DataCategorySinze.getGc_Id_3();
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
	/**
	 * 讀取，並寫入第一層的程式碼
	 * @throws SQLException
	 * @throws ClassNotFoundException
	 */
	public static void getDeepZeroS() throws SQLException, ClassNotFoundException{
		String URL = "jdbc:mysql://localhost:3306/sakila?characterEncoding=UTF-8";
		String USER = "root";
		String PASSWORD = "root";
		// 1.載入驅動程式
		Class.forName("com.mysql.jdbc.Driver");
		// 2.獲得資料庫連結
		Connection conn = DriverManager.getConnection(URL, USER, PASSWORD);
		// 3.通過資料庫的連線操作資料庫，實現增刪改查（使用Statement類）
		Statement st = conn.createStatement();
		ResultSet rs = st
				.executeQuery("select DISTINCT gc_id_1 from 33hao_goods_class_staple");
		while (rs.next()) {
			String gc_id_1 = rs.getString("gc_id_1");
			DataCategorySinze.getGc_Id_1S(gc_id_1);
//			DataCategorySinze.getGc_Id_1(gc_id_1,1,count);
			System.out.println(gc_id_1);
		}
		rs.close();
		st.close();
		conn.close();
	}
	
	public static void getGc_Id_1S(String gc_id_1) throws SQLException, ClassNotFoundException{
		String URL = "jdbc:mysql://localhost:3306/sakila?characterEncoding=UTF-8";
		String USER = "root";
		String PASSWORD = "root";
		String sql = "SELECT gc_name as name,jx as catCode from 33hao_goods_class WHERE gc_id ="+gc_id_1;
		// 1.載入驅動程式
		Class.forName("com.mysql.jdbc.Driver");
		// 2.獲得資料庫連結
		Connection conn = DriverManager.getConnection(URL, USER, PASSWORD);
		// 3.通過資料庫的連線操作資料庫，實現增刪改查（使用Statement類）
		Statement st = conn.createStatement();
		ResultSet rs = st.executeQuery(sql);
		while (rs.next()) {
			String name = rs.getString("name");
			String catCode = rs.getString("catCode");
			DataCategorySinze.inserDeepZero(name, 0, catCode, 0);
			System.out.println(name+" "+catCode+" ");
		}
		rs.close();
		st.close();
		conn.close();
	}
	
	/**
	 * 讀取，並寫入第二層的程式碼
	 * @param count
	 * @throws SQLException
	 * @throws ClassNotFoundException
	 */
	public static void getDeepZero(int count) throws SQLException, ClassNotFoundException{
		String URL = "jdbc:mysql://localhost:3306/sakila?characterEncoding=UTF-8";
		String USER = "root";
		String PASSWORD = "root";
		// 1.載入驅動程式
		Class.forName("com.mysql.jdbc.Driver");
		// 2.獲得資料庫連結
		Connection conn = DriverManager.getConnection(URL, USER, PASSWORD);
		// 3.通過資料庫的連線操作資料庫，實現增刪改查（使用Statement類）
		Statement st = conn.createStatement();
		ResultSet rs = st
				.executeQuery("select DISTINCT gc_id_1 from 33hao_goods_class_staple");
		while (rs.next()) {
			count++;
			String gc_id_1 = rs.getString("gc_id_1");
			DataCategorySinze.getGc_Id_1(gc_id_1,1,count);
			System.out.println(gc_id_1);
		}
		rs.close();
		st.close();
		conn.close();
	}
	
	
	public static void getGc_Id_1(String gc_parent_id,int deep,int count) throws SQLException, ClassNotFoundException{
		String URL = "jdbc:mysql://localhost:3306/sakila?characterEncoding=UTF-8";
		String USER = "root";
		String PASSWORD = "root";
		String sql = "SELECT gc_name as name,jx as catCode from 33hao_goods_class WHERE gc_parent_id ="+gc_parent_id;
		// 1.載入驅動程式
		Class.forName("com.mysql.jdbc.Driver");
		// 2.獲得資料庫連結
		Connection conn = DriverManager.getConnection(URL, USER, PASSWORD);
		// 3.通過資料庫的連線操作資料庫，實現增刪改查（使用Statement類）
		Statement st = conn.createStatement();
		ResultSet rs = st.executeQuery(sql);
		while (rs.next()) {
			String name = rs.getString("name");
			String catCode = rs.getString("catCode");
			Integer parentId = Integer.valueOf(count);
			DataCategorySinze.inserDeepZero(name, parentId, catCode, deep);
//			DataCategorySinze.getGc_Id_1(String.valueOf(deep), 2, 0);
			System.out.println(name+" "+catCode+" "+parentId);
		}
		rs.close();
		st.close();
		conn.close();
	}
	
	/**
	 * 讀取，並寫入第三層的程式碼
	 * @throws ClassNotFoundException
	 * @throws SQLException
	 */
	public static void getGc_Id_3() throws ClassNotFoundException, SQLException{
		String URL = "jdbc:mysql://localhost:3306/sakila?characterEncoding=UTF-8";
		String USER = "root";
		String PASSWORD = "root";
		// 1.載入驅動程式
		Class.forName("com.mysql.jdbc.Driver");
		// 2.獲得資料庫連結
		Connection conn = DriverManager.getConnection(URL, USER, PASSWORD);
		// 3.通過資料庫的連線操作資料庫，實現增刪改查（使用Statement類）
		Statement st = conn.createStatement();
		ResultSet rs = st
				.executeQuery("select DISTINCT gc_id_3 from 33hao_goods_class_staple");
		while (rs.next()) {
			String gc_id_3 = rs.getString("gc_id_3");
			DataCategorySinze.getGc_Id_3_GetParentInfo(gc_id_3);
			System.out.println(gc_id_3);
		}
		rs.close();
		st.close();
		conn.close();
	}
	
	public static void getGc_Id_3_GetParentInfo(String gc_id_3) throws ClassNotFoundException, SQLException{
		String URL = "jdbc:mysql://localhost:3306/sakila?characterEncoding=UTF-8";
		String USER = "root";
		String PASSWORD = "root";
		// 1.載入驅動程式
		Class.forName("com.mysql.jdbc.Driver");
		// 2.獲得資料庫連結
		Connection conn = DriverManager.getConnection(URL, USER, PASSWORD);
		// 3.通過資料庫的連線操作資料庫，實現增刪改查（使用Statement類）
		Statement st = conn.createStatement();
		ResultSet rs = st
				.executeQuery("select gc_name as name,gc_parent_id,jx as catCode   from 33hao_goods_class where gc_id ="+gc_id_3);
		while (rs.next()) {
			String gc_parent_id = rs.getString("gc_parent_id");
			String name = rs.getString("name");
			String catCode = rs.getString("catCode");
			DataCategorySinze.getGc_Id_3_GetParentInfoDeatil(gc_parent_id,name,catCode);
			System.out.println(gc_parent_id);
		}
	}
	
	public static void getGc_Id_3_GetParentInfoDeatil(String gc_parent_id,String name,String catCode) throws SQLException, ClassNotFoundException{
		String URL = "jdbc:mysql://localhost:3306/sakila?characterEncoding=UTF-8";
		String USER = "root";
		String PASSWORD = "root";
		// 1.載入驅動程式
		Class.forName("com.mysql.jdbc.Driver");
		// 2.獲得資料庫連結
		Connection conn = DriverManager.getConnection(URL, USER, PASSWORD);
		// 3.通過資料庫的連線操作資料庫，實現增刪改查（使用Statement類）
		Statement st = conn.createStatement();
		ResultSet rs = st
				.executeQuery("select  *   from 33hao_goods_class where gc_id = "+gc_parent_id);
		while (rs.next()) {
			String gc_name = rs.getString("gc_name");
			ResultSet set = DataCategorySinze.getNewTablesInfo();
			while (set.next()) {
				String string = set.getString("name");
				String id = set.getString("id");
				Integer parentId = Integer.valueOf(id);
				if (gc_name.equals(string)) {
//					for (int i = 0; i < list.size(); i++) {
//						ResultSet resultSet = list.get(i);
							DataCategorySinze.inserDeepZero(name, parentId, catCode, 2);
//					}
				}
			}
		}
		rs.close();
		st.close();
		conn.close();
	}
	
	public static ResultSet getNewTablesInfo() throws SQLException, ClassNotFoundException{
		String URL = "jdbc:mysql://localhost:3306/sb_01?characterEncoding=UTF-8";
		String USER = "root";
		String PASSWORD = "root";
		// 1.載入驅動程式
		Class.forName("com.mysql.jdbc.Driver");
		// 2.獲得資料庫連結
		Connection conn = DriverManager.getConnection(URL, USER, PASSWORD);
		// 3.通過資料庫的連線操作資料庫，實現增刪改查（使用Statement類）
		Statement st = conn.createStatement();
		ResultSet rs = st
				.executeQuery("select id,name,parentId,catCode,deep from merchandisecategory where deep =1");
		return rs;
	}
	
	public static void inserDeepZero( String name, int parentId,
			String catCode, int deep) throws ClassNotFoundException, SQLException{
		String URL = "jdbc:mysql://localhost:3306/sb_01?characterEncoding=UTF-8";
		String USER = "root";
		String PASSWORD = "root";
		String sql = "INSERT INTO merchandisecategory ( name, parentId, catCode, deep) VALUES (  ?, ?, ?, ?)";
		int executeUpdate = 0;
		// 1.載入驅動程式
		Class.forName("com.mysql.jdbc.Driver");
		// 2.獲得資料庫連結
		Connection conn = DriverManager.getConnection(URL, USER, PASSWORD);
		// 3.通過資料庫的連線操作資料庫，實現增刪改查（使用Statement類）
		PreparedStatement pstmt;
		try {
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, name);
			pstmt.setInt(2, parentId);
			pstmt.setString(3, catCode);
			pstmt.setInt(4, deep);
			executeUpdate = pstmt.executeUpdate();
			pstmt.close();
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
		// 關閉資源
		conn.close();
	}
	
	
	/**
	 * 獲取被複制資料
	 * 
	 * @throws SQLException
	 * @throws ClassNotFoundException
	 */
	public static void getSqlQuery() throws SQLException,
			ClassNotFoundException {
		String URL = "jdbc:mysql://localhost:3306/sakila?characterEncoding=UTF-8";
		String USER = "root";
		String PASSWORD = "root";
		// 1.載入驅動程式
		Class.forName("com.mysql.jdbc.Driver");
		// 2.獲得資料庫連結
		Connection conn = DriverManager.getConnection(URL, USER, PASSWORD);
		// 3.通過資料庫的連線操作資料庫，實現增刪改查（使用Statement類）
		Statement st = conn.createStatement();
		ResultSet rs = st
				.executeQuery("select gc_id as id,gc_name as name,jx as catCode , gc_parent_id as parentId,gc_sort as deep from 33hao_goods_class");
		// 4.處理資料庫的返回結果(使用ResultSet類)
		while (rs.next()) {
			Integer valueOf = Integer.valueOf(rs.getString("deep"));
			Integer id = Integer.valueOf(rs.getString("id"));
			Integer parentId = Integer.valueOf(rs.getString("parentId"));
			DataCategory.insertIntoCategory(id, rs.getString("name"), parentId,
					rs.getString("catCode"), valueOf);
			System.out.println(id + " " + " " + parentId + valueOf + " "
					+ rs.getString("deep") + " " + rs.getString("name"));
		}
		// 關閉資源
		rs.close();
		st.close();
		conn.close();
	}

	/**
	 * 插入目標資料庫表中相應的欄位值
	 * 
	 * @param id
	 * @param name
	 * @param parentId
	 * @param catCode
	 * @param deep
	 * @throws ClassNotFoundException
	 * @throws SQLException
	 */
	public static void insertIntoCategory(int id, String name, int parentId,
			String catCode, int deep) throws ClassNotFoundException,
			SQLException {
		String URL = "jdbc:mysql://localhost:3306/sb_01?characterEncoding=UTF-8";
		String USER = "root";
		String PASSWORD = "root";
		String sql = "INSERT INTO merchandisecategory ( id, name, parentId, catCode, deep) VALUES ( ?, ?, ?, ?, ?)";
		int executeUpdate = 0;
		// 1.載入驅動程式
		Class.forName("com.mysql.jdbc.Driver");
		// 2.獲得資料庫連結
		Connection conn = DriverManager.getConnection(URL, USER, PASSWORD);
		// 3.通過資料庫的連線操作資料庫，實現增刪改查（使用Statement類）
		PreparedStatement pstmt;
		try {
			pstmt = conn.prepareStatement(sql);
			pstmt.setInt(1, id);
			pstmt.setString(2, name);
			pstmt.setInt(3, parentId);
			pstmt.setString(4, catCode);
			pstmt.setInt(5, deep);
			executeUpdate = pstmt.executeUpdate();
			pstmt.close();
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
		// 關閉資源
		conn.close();
	}
}

相關推薦

Java實現簡單的資料遷移，從單庫單表到單庫單表（2）

這個文章是對我上一篇文章Java實現簡單的資料遷移，從單庫單表到單庫單表的簡單擴充套件因為我上一篇文章那種方法只能把資料進行簡單的遷移，但是這裡我需要對資料庫的內容進行重新的編排，所以很顯然，我上一篇文章的寫法是沒法完成我的需求的。 重申一下需求： 從一張資料表

從零寫分散式RPC框架 系列 1.0 （2）RPC-Common模組設計實現

RPC-Common模組提供RPC-Server和RPC-Client的通用物件，封裝統一規則，使RPC Server和RPC Client 可以基於同一協議通訊。主要包含底層通訊的Netty所需的編碼解碼器（RpcEncoder，RpcDecoder），實現自定義協議的傳輸物件（Rpc

非 Java、C、Python，使用的第一門計算機語言是它！（下）

屏幕 支持 brin roi 廣告 pri 領域 eat https “我意識到我們可以為它編寫一個程序，而且它的能力足夠運行 BASIC。” 眾所周知，他們在編寫 Altair BASIC 的初稿時甚至沒有一個可以訪問的Altair，所以他們在數字設備 PDP-10 的小

從0開始，部署.NetCore並構建非阻塞高併發伺服器（2）

工具篇看我這篇部落格想搭建伺服器的朋友多半是想在Linux上使用，正所謂工欲善其事必先利其器，一個好用的SSH對我們的工作效率影響也很大，簡單的說下我在Win下常用的SSH軟體和使用教程，老手自動忽略即可推薦工具1--WinSCPWinSCP可以說是我最常用的遠端連線Linu

SQL從零到迅速精通【實用函數（2）】

表的操作 deny 獲取 拒絕 分享 子字符串 evo sci ever 1.對查詢結果進行排序 查詢stu_info表中所有學生信息，並按照成績由高到底進行排序，輸入語句如下。 SELECT * FROM stu_info ORDER BY s_score DESC;

MySQL5.7從入門到精通-------儲存過程與儲存函式（2）

10.1.6  流程控制的使用         （1）IF語句的使用。 DROP PROCEDURE IF EXISTS testIf; DELIMITER // CREATE PROCEDURE

大資料學習之Scala中main函式的分析以及基本規則（2）

一、main函式的分析 首先來看我們在上一節最後看到的這個程式，我們先來簡單的分析一下，有助於後面的學習 object HelloScala { def main(args: Array[String]): Unit = { printl

用java實現簡單快速的webservice客戶端/資料採集器（支援soap1.1和soap1.2標準，支援utf-8編碼）

前言： 用了cxf，axis等各種wbeservice實現庫，簡單試用了一下動態呼叫的方式，很不滿意，完全無法滿足業務的需要，所以自己實現了一個webservice採集客戶端，方便動態呼叫外部webservice介面。 一、實現的功能 1、soap1.1客戶端（soap1.

java實現k-means演算法（用的鳶尾花iris的資料集，從mysq資料庫中讀取資料）

k-means演算法又稱k-均值演算法，是機器學習聚類演算法中的一種，是一種基於形心的劃分方法，其中每個簇的中心都用簇中所有物件的均值來表示。其思想如下： 輸入： k：簇的數目；D：包含n個物件的資料集。輸出：k個簇的集合。 方法： 從D中隨機選擇幾個物件作為起始質心

java實現簡單的單點登錄 （轉）

hresult 調查公司 exe ftp 說我 負數 是我 create 統一 摘要：單點登錄（SSO）的技術被越來越廣泛地運用到各個領域的軟件系統當中。本文從業務的角度分析了單點登錄的需求和應用領域；從技術本身的角度分析了單點登錄技術的內部機制和實現手段，並且給出Web-

Java實現簡單的資料結構(五)

(5)二叉樹 public class BinaryTreeNode { private Comparable data; private BinaryTreeNode root; private BinaryTreeNode left; private BinaryTreeN

Java實現簡單的資料結構(四)

(4)Queue import org.junit.Test; public class Queue { private int size = 0; private LinkedList linkedList = new LinkedList(); /** * 入隊方法

Java實現簡單的資料結構(三)

(3)Stack package com.coding.basic; import org.junit.Test; public class Stack { private ArrayList elementData = new ArrayList(); /** * 壓棧

Java實現簡單的資料結構(二)

2.LinkedList import java.util.NoSuchElementException; import org.junit.Test; public class LinkedList implements List { private Node first;

Java實現簡單的資料結構(一)

利用Java語言實現簡單的資料結構,Java中動態擴容的ArrayList,LinkedList,Stack,Queue以及二叉樹 1.ArrayList import java.util.Arrays; import org.junit.Test; public class A

java實現簡單的快速排序，合併排序

合併排序 public class MergeSort{ public static void merge(int[]c,int[]d,int l,int m,int r){ //合併c[l:m]和c[m+1:r]到d[l:r] int i=l,j=m+1,k=l;

JAVA實現簡單的Session登入，登出功能

session常常用來儲存使用者的登入資訊。那麼伺服器是怎麼來實現的呢？這裡我簡單模擬一下。 第一步，編寫登入主頁： <!DOCTYPE html> <html> <head> <title>登陸頁面</ti

資料搬遷，從GCP Storage 遷移到阿里雲儲存(OSS) « 關於網路那些事...

通常在建構系統中，擴充新服務，在遷移過程，有時會需要將雲端資料進行搬移 最近剛好一個系統需要將GCP上面的Storage資料遷移到阿里雲OSS 在這裡做一個紀錄

JAVA實現 簡單搶紅包演算法，模擬真實搶紅包。

import java.math.BigDecimal; import java.util.ArrayList; import java.util.Collections; import java.util.List; import java.util.Random; p

SpringBoot簡單專案搭建，從資料讀取資料展示到頁面

springboot快速搭建web專案，無需繁瑣xml配置，熱部署，無需重啟伺服器，簡單部署只需打jar包即可，有很多的優點！ 剛接觸到springboot花費了好幾個小時，擼完一個又一個的配置坑，最終實現從資料庫成功讀取資料展示到頁面！ 希望對你能有所幫助！