DBOutputFormat把MapReduce结果输出到mysql中

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);

}

}

更多请见：https://blog.csdn.net/qq_44594249/article/details/97612412