connect1.java

一个简单的人事管理系统。通过swing、jdbc实现。并利用xml实现输出

package ConnectSQL;

import java.sql.*;
import java.util.*;

import javax.swing.table.DefaultTableModel;

import JianTing.JianT;

public class Connect1 {
	public ArrayList al = null;

	private DefaultTableModel model = new DefaultTableModel();

	Connection conn = null;

	Statement stmt = null;

	ResultSet rs = null;

	private void connect() {
		try {
			Class.forName("com.mysql.jdbc.Driver");
			conn = DriverManager
					.getConnection("jdbc:mysql://localhost/mydata?user=root&password=mysql&characterEncoding=GB2312");
			stmt = conn.createStatement();
		} catch (ClassNotFoundException ex) {
			ex.printStackTrace();
		} catch (SQLException ex) {
			System.out.println("SQLException: " + ex.getMessage());
			System.out.println("SQLState: " + ex.getSQLState());
			System.out.println("VendorError: " + ex.getErrorCode());
		}
	}

	public void getConnect() {
		connect();
		try {
			rs = stmt.executeQuery("select * from renshi");
			al = new ArrayList();
			String[] str = new String[5];
			while (rs.next()) {
				ArrayList rowData = new ArrayList();
				for (int i = 0; i < 5; i++) {
					str[i] = rs.getString(i + 1);
					rowData.add(str[i]);
				}
				al.add(rowData);
			}
		} catch (SQLException ex) {
			System.out.println("SQLException: " + ex.getMessage());
			System.out.println("SQLState: " + ex.getSQLState());
			System.out.println("VendorError: " + ex.getErrorCode());
		} finally {
			close();
		}
	}

	public void insert() {
		for (int j = 0; j < JianT.djt.getRowCount(); j++) {
			String[] str = new String[5];
			for (int i = 0; i < 5; i++) {
				str[i] = (String) JianT.djt.getValueAt(j, i);
			}
			if (str[0] != null) {
				try {
					connect();
					stmt
							.executeUpdate("insert into renshi (ID,Name,Sex,Department,Salary) values('"
									+ str[0]
									+ "','"
									+ str[1]
									+ "','"
									+ str[2]
									+ "','" + str[3] + "','" + str[4] + "')");
				} catch (SQLException e) {
					e.printStackTrace();
					System.out.println("您的输入有误！");
				}
				close();
			}
		}
	}

	public void delete() {
		String s = JianT.jtf1.getText();
		if (s != null) {
			try {
				connect();
				int n = stmt.executeUpdate("delete from renshi where ID='" + s
						+ "'");
				if (n == 0) {
					System.out.println("相关信息不存在！");
				}
			} catch (SQLException e) {
				e.printStackTrace();
				System.out.println("连接数据库失败！");
			}
			close();
		}
	}

	public void update() {
		String s1 = JianT.jtf1.getText();
		String s2 = JianT.jtf2.getText();
		String s3 = JianT.jtf3.getText();
		String s4 = JianT.jtf4.getText();
		String s5 = JianT.jtf5.getText();
		if (s1 != null) {
			try {
				connect();
				int n = stmt.executeUpdate("update renshi set Name='" + s2
						+ "',Sex='" + s3 + "',Department='" + s4 + "',Salary='"
						+ s5 + "'where ID='" + s1 + "'");
				if (n == 0) {
					System.out.println("未找到相关信息，更新失败！");
				}
			} catch (SQLException e) {
				e.printStackTrace();
				System.out.println("连接数据库出错");
			}
			close();
		}
	}

	public void query() {
		String s1 = JianT.jtf1.getText();
		if (s1 != null) {
			try {
				connect();
				rs = stmt.executeQuery("select * from renshi where ID='" + s1
						+ "'");
				String str = new String();
				Vector vec = new Vector();
				while (rs.next()) {
					for (int i = 0; i < 5; i++) {
						str = rs.getString(i + 1);
						vec.add(str);
					}
				}
				model = JianT.model;
				model.addRow(vec);
				JianT.djt.setModel(model);
				JianT.jtf1.setText("");
			} catch (SQLException e) {
				e.printStackTrace();
				System.out.println("输入有误！");
			}
			close();
		}
	}

	private void close() {
		try {
			if (rs != null) {
				rs.close();
				rs = null;
			}
			if (stmt != null) {
				stmt.close();
				stmt = null;
			}
			if (conn != null) {
				conn.close();
				conn = null;
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
}