domysql.java

是mysql数据库数据导入程序是从excel中提取数据导入到mysql数据库中

package com.mysql;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import com.conn.ConnDb;

public class Domysql {

	/**
	 * @param args
	 */
	private Connection conn = null;
	private Statement st = null;
	private ResultSet rs = null;

	public void insert(String shuju, String id, String leixing) {
		ConnDb db = new ConnDb();
		conn = db.getConn();
		String t = "2008,6";
		String linshit = null;
		String biaoming = null;
		String ziduan = null;
		String cn = null;
		String t1 = null;
		String t2 = null;
		String t3 = null;
		String t4 = null;
		String sql = "select * from mt1 where C=" + id;
		String ins = null;
		try {
			st = conn.createStatement();
			// System.out.println(sql);
			rs = st.executeQuery(sql);
			while (rs.next()) {
				cn = rs.getString("CN");
				ziduan = cn + leixing;
				t1 = rs.getString("T1");
				t2 = rs.getString("T2");
				t3 = rs.getString("T3");
				t4 = rs.getString("T4");
				biaoming=t1+"_"+t2+"_"+t3+"_"+t4;
			}
			if (cn!=null&&t1!=null&&t2!=null&&t3!=null&&t4!=null) {

				String lingshisql="select T from " + biaoming + " where T='"+ t+"'";
				// System.out.println(lingshisql);
				rs = st.executeQuery(lingshisql);
				while (rs.next()) {
					linshit = rs.getString("T");
				}
				if (linshit != null || linshit != "")
					ins = "update " + biaoming + " set " + ziduan + " =("
							+ shuju.trim() + ") where T='" + t+"'";
				if (linshit == null || linshit == "")
					ins = "insert into " + biaoming + " (T," + ziduan
							+ ") values ('" + t + "','" + shuju.trim() + "')";
				System.out.println(ins + "  " + id);
				 st.executeUpdate(ins);
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {
			db.close();
		}
	}

	public static void main(String[] args) {
		// TODO Auto-generated method stub

	}

}