??? 不管你的程序员生涯是不是从做数据库应用开始的，反正我是的。

?

??? 刚刚使用java那时，除了会写个hello world以外，参加的面试都会问你，会不会java数据库操作？答曰：会！再问：请详细描述。答曰：JDBC。

?

??? 后来的工作中写代码，写的最多的就是JDBC的应用，创建connection，创建Statement，创建ResultSet，遍历......周而复始，好像深山中樵夫砍柴，一刀一个印，单调乏味，却乐此不彼。

?

?

??? 言归正传，本文就从自己使用JDBC讲起，对自己在java数据库操作方面做一个小结，温故知新，回忆往昔。

?

??? 接下来，考虑到例子的简易性，数据库就使用sqlite 。例子中所有的操作基于以下几个表：

• 部门表
• 员工表
• 技能表
• 员工技能关系表

图1： 表结构定义

?

建表SQL如下

?

CREATE TABLE Department (id NUMERIC, name TEXT, description TEXT);

CREATE TABLE Employee (id NUMERIC, name TEXT, departmentid NUMERIC, description TEXT);

CREATE TABLE Skill (id NUMERIC, name TEXT);

CREATE TABLE EmpSkill (empid NUMERIC, skillid NUMERIC);

?

??? 其中，Department和employee是一对多的关系，employee和skill表是多对多关系。

?

??? 项目需要：

• 部门表、员工表、技能表可以CRUD
• 删除部门，员工表的对应的部门ID设置为空
• 删除员工，员工技能关系表要对应删除
• 删除技能，要检查这项技能有没有被员工使用，如果有，则不允许删除，要先把员工和技能对应关系删除后，再进行删除

?

??? 好吧，我承认，一开始我就是直接写代码开始做了，大概是这样子的：

package cn.lettoo.jdbc;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

public class DepartmentDB {

	public void addDepartment(Connection conn, Department dept)
			throws SQLException {
		Statement stmt = conn.createStatement();
		String sql = "INSERT INTO DEPARTMENT(ID, NAME, DESCRIPTION) VALUES ("
				+ dept.getId() + ", \"" + dept.getName() + "\", \""
				+ dept.getDescription() + "\")";
		stmt.execute(sql);
	}
	
	public void deleteDepartment(Connection conn, Department dept)
			throws SQLException {
		Statement stmt = conn.createStatement();
		String sql = "DELETE FROM DEPARTMENT WHERE ID = " + dept.getId();
		stmt.execute(sql);
	}
	
	public void updateDepartment(Connection conn, Department dept) throws SQLException {
		Statement stmt = conn.createStatement();
		String sql = "UPDATE DEPARTMENT SET NAME = \"" + dept.getName() + "\", DESCRIPTION =\""
				+ dept.getDescription() + "\" WHERE ID = "+ dept.getId();
		stmt.execute(sql);
	}
	
	public List<Department> selectDepartment(Connection conn, String condition) throws SQLException {
		Statement stmt = conn.createStatement();
		String sql = "SELECT ID, NAME, DESCRIPTION FROM DEPARTMENT WHERE " + condition;
		ResultSet rs = stmt.executeQuery(sql);
		List<Department> deptList = new ArrayList<Department>();
		
		while(rs.next()) {			
			Department dept = new Department();
			dept.setId(rs.getInt("ID"));
			dept.setName(rs.getString("NAME"));
			dept.setDescription(rs.getString("DESCRIPTION"));
			deptList.add(dept);			
		}
		
		return deptList;
	}
}

测试类大概是这样：

package cn.lettoo.jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.List;

public class JdbcTest {

    /**
     * @param args
     * @throws ClassNotFoundException 
     * @throws SQLException 
     */
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
        String url = "jdbc:sqlite:test.db";
        Class.forName("org.sqlite.JDBC");
        Connection conn=DriverManager.getConnection(url);
        
        DepartmentDB deptDB = new DepartmentDB();
        Department dept1 = new Department();