DBOutputFormat把MapReduce結果輸出到mysql中
現在有一個需求：就是如何使用DBOutputFormat把MapReduce產生的結果輸出到mysql中。

package com;
import java.io.File;
import java.io.IOException;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.apache.commons.lang.StringUtils;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Job;
import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.mapreduce.Reducer;
import org.apache.hadoop.mapreduce.lib.db.DBConfiguration;
import org.apache.hadoop.mapreduce.lib.db.DBOutputFormat;
import org.apache.hadoop.mapreduce.lib.db.DBWritable;
import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
public class mysqlTestMark_to_win {
public static class MytableWritable implements DBWritable {
String name;
int age;

public MytableWritable() {
}

public MytableWritable(String name, int age) {
this.name = name;
this.age = age;
}

public void write(PreparedStatement statement) throws SQLException {
System.out.println("write PreparedStatement");
statement.setString(1, this.name);
statement.setInt(2, this.age);
}

public void readFields(ResultSet resultSet) throws SQLException {
/*因為不用從資料庫中讀，所以可以這裡遮蔽程式碼， 因為上面是介面，所以必須實現這個方法*/
// System.out.println("readFields ResultSet");
// this.name = resultSet.getString(1);
// this.age = resultSet.getInt(2);
}
public String toString() {
return new String(this.name + " " + this.age);
}
}

更多內容請見原文，文章轉載自：