public class BatchTest{
    private final static Connection connection = DriverManager.getConnection(
						this.url + this.dbName + "?characterEncoding=UTF-8&serverTimezone=UTC&useSSL=false",
						this.username, this.password);

    public static void main(String[] args){
		String query = "INSERT INTO DOC VALUES(?, ?, ?)";
		
        // 데이터 파일에서 documents를 읽어와 List<String[]> 형태로 리턴하는 가상의 함수
        List<String[]> documents = getDocumentsFromFile();

		PreparedStatement pstmt = null;
		try {
            // AutoCommit을 지원하는 DB일 경우 default가 true인 경우가 있기에 꼭 이 과정을 거쳐야함.
			this.connection.setAutoCommit(false);
			pstmt = this.connection.prepareStatement(query);
			
			int size = 0;
            
			for(String[] doc : documents) {
				int i = 1;

			    // documents의 field를 순회하면서 pstmt에 파라미터 추가
				for(String col : doc) {
					pstmt.setObject(i++, col);
				}

				// batch에 현재 루프에 파라미터가 추가된 pstmt를 추가
				pstmt.addBatch();
				
				size++;
				
                // 일정 갯수(1000개)를 넘기면 batch 실행 후 commit
				if(size > 1000) {
					pstmt.executeBatch();
					connection.commit();
					pstmt.clearBatch();
					size = 0;
				}
			}
            // 일정 갯수가 채워지지 않고 끝난 나머지 batch를 실행 후 commit()
			pstmt.executeBatch();
            connection.commit();
            pstmt.clearBatch();
		} catch (SQLException e) {
			e.printStackTrace();
			return;
		}
    }
}

public class BatchTest{
    public static void main(String[] args){
		long start = System.currentTimeMillis();

		// Data File 경로
		String path = "C:\\training\\DBnFile\\data\\doc.tsv";

		Connector mysqlConnector = new Connector("jdbc:mysql://localhost:3306/", "root", "daummove02");
		mysqlConnector.setDbName("training1");
		mysqlConnector.setTableName("DOC4");

		DAO<Document> dao = new DocumentDAO(mysqlConnector.connect(), mysqlConnector.getTableName());
		dao.setColNames();
		
		fileToDB(path, dao);
		long end = System.currentTimeMillis();

		System.out.println("걸린 시간 : " + (end - start) / 1000 + "sec");

		mysqlConnector.close();
    }

    // TsvReader를 이용해 파일을 읽어 bundle에 추가하는 함수.
    public static void fileToDB(String path, DAO<Document> dao) {
		TsvReader tsvReader = new TsvReader();

		List<String[]> lines = tsvReader.readFile(path);
		List<String[]> bundle = new ArrayList<>();

		for (String[] line : lines) {
			bundle.add(line);
            // bundle의 사이즈가 1000이면 한 번에 insert
			if (bundle.size() > 1000) {
				dao.insert(bundle);
				bundle.clear();
			}
		}

		dao.insert(bundle);
	}
}

public class DocumentDAO implements DAO<Document>{
    // 4. insert 1000 documents at once using multiple insert query
	@Override
	public void insert(List<String[]> bundle) {
		StringBuilder paramsBuilder = new StringBuilder("?");

		for (int i = 0; i < this.colNames.size() - 1; i++)
			paramsBuilder.append(", ?");

		String params = paramsBuilder.toString();
		String query = "INSERT INTO " + this.tabName + " VALUES (" + params + ")";
		PreparedStatement pstmt = null;
		try {
			int i = 1;
			for (int j = 1; j < bundle.size(); j++) {
				query += ",\n(" + params + ")";
			}

			pstmt = this.connection.prepareStatement(query);
			
			for (String[] doc : bundle) {
				for (String col : doc) {
					pstmt.setObject(i++, col);
				}
			}
			try {
				pstmt.execute();
			} catch (SQLIntegrityConstraintViolationException e) {
				e.printStackTrace();
			}
			pstmt.close();
		} catch (SQLException e) {
			e.printStackTrace();
			return;
		}
	}
}