public class GarbageData {

	private long id;

	private String comment;

	

	public void setID(long id){

		this.id = id;

	}

	public long getID(){

		return this.id;

	}

	

	public void setComment(String comment){

		this.comment = comment;

	}

	public String getComment(){

		return this.comment;

	}

}


    

      import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.ArrayList;

import java.util.List;

import org.apache.log4j.Logger;



public class UpdateFeature {

	private Connection m_connection;

	private Statement m_statement;

	private ResultSet m_resultSet;

	private String m_strUrl;

	private String m_strDBUser;

	private String m_strDBPass;

	private static final Logger logger = Logger.getLogger(UpdateFeature.class);

	

	public UpdateFeature(String strUrl,String strDBUser,String strDBPass){

		this.m_strUrl = strUrl;

		this.m_strDBUser = strDBUser;

		this.m_strDBPass = strDBPass;

		this.connDB();

	}

	public int connDB(){

		try{

			Class.forName("org.gjt.mm.mysql.Driver");

			this.m_connection = DriverManager.getConnection(this.m_strUrl,this.m_strDBUser,this.m_strDBPass);

			this.m_statement = this.m_connection.createStatement(ResultSet.TYPE_FORWARD_ONLY,ResultSet.CONCUR_READ_ONLY);

			this.m_statement.setFetchSize(Integer.MIN_VALUE);

		}catch(ClassNotFoundException e){

			logger.error("Class not found exception.");

			logger.error(e.getMessage(),e);

			return -1;

		}catch(SQLException ex){

			logger.error("Connnect to " + this.m_strUrl + " failed!");

			logger.error(ex.getMessage(),ex);

		}

		return 0;

	}

	public Statement getStatement(){

		return this.m_statement;

	}

	public void updateFeature() throws SQLException{

		String getSql = "SELECT * FROM `generalantispam`.`GarbageFeature` where insertTime > " + "\"2012-12-15 00:00:00\" and insertTime < " + "\"2012-12-18 00:00:00\"" + " order by garbageid desc";

		logger.info(getSql);

		ResultSet rs = this.m_statement.executeQuery(getSql);

		List<GarbageData> dataList = new ArrayList<GarbageData>();

		while (rs.next()){

			GarbageData data = new GarbageData();

			long garbageID = rs.getLong("garbageID");

			String strComment = rs.getString("garbage");

			String[] comments = strComment.split(";;;");

			String strGarbage = comments[0];

			data.setID(garbageID);

			strGarbage = strGarbage.replaceAll("\"", "");

			data.setComment(strGarbage);

			dataList.add(data);

			logger.info(strComment);

		}

		logger.info("List size: " + dataList.size());

		this.m_connection.setAutoCommit(false);

		for(int i = 0; i < dataList.size(); i++){

			GarbageData data = dataList.get(i);

			String strSql = "update `generalantispam`.`GarbageFeature` set garbage=\"" + data.getComment() + "\" where garbageID =" + data.getID() ;

			logger.info(strSql);

			this.m_statement.executeUpdate(strSql);

			if (i % 50 == 0)

				this.m_connection.commit();

		}

		this.m_connection.commit();

	}

	public void close(){

		try {

			if (this.m_resultSet != null)

				m_resultSet.close();

			if (this.m_statement != null)

				m_statement.close();

			if (this.m_connection != null)

				m_connection.close();

		} catch (Exception e) {

			logger.equals(e.getMessage());

		}

	}

	public static void main(String[] args) {

		UpdateFeature upF = new UpdateFeature("jdbc:mysql://xxx.xxx.xxx.xxx:3306/generalantispam","garbage", "garbage");

		try {

			upF.updateFeature();
      

      　　　　                        upF.close();

		} catch (SQLException e) {

			e.printStackTrace();

		}

	}



}