Java学习系列(十九)Java面向对象之数据库编程

JDBC（Java Data Base Connectivity：java数据库连接）：它定义了一组标准的操作数据库的接口，既然是接口，那它就是一种规范，是Java操作数据库的技术规范。

Java数据库编程有两步常用操作：

1.加载(或注册)JDBC驱动程序
Class.forName(“com.mysql.jdbc.Driver”); 推荐这种方式，不会对具体的驱动类产生依赖。
DriverManager.registerDriver(com.mysql.jdbc.Driver); 会造成DriverManager中产生两个一样的驱动，并会对具体的驱动类产生依赖。

2.建立数据库Connection
Connection conn = DriverManager.getConnection(url, user, password);DriverManager是一个驱动管理器，内部有一个驱动注册表（Map结构），可以向其注册多个JDBC驱动。

举例说明1：

 

/**
 * @author lhy
 * @description 数据库工具类
 */
public class DBUtil {
	// 创建连接
	public static Connection createConn() {
		Connection conn = null;
		try {
			// 加载驱动程序
			Class.forName("com.mysql.jdbc.Driver");
			// 获取连接(这里用户名为root，密码为空)
			conn = DriverManager.getConnection(
					"jdbc:mysql://localhost:3306/test", "root", "");
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return conn;
	}

	// 创建回话,获取预处理语句（可以防止sql语句注入）
	public static PreparedStatement prepare(Connection conn, String sql) {
		PreparedStatement ps = null;
		try {
			ps = conn.prepareStatement(sql);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return ps;
	}

	// 关闭连接
	public static void close(Connection conn) {
		if (conn != null) {
			try {
				conn.close();
				conn = null;
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

	// 关闭回话
	public static void close(Statement st) {
		if (st != null) {
			try {
				st.close();
				st = null;
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

	// 关闭查询结果集
	public static void close(ResultSet rs) {
		if (rs != null) {
			try {
				rs.close();
				rs = null;
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}
}

 

下面用户表为例，调用Statement对象的executeQuery()方法或executeUpdate()方法，让DBMS 执行具体的SQL语句，以便对数据执行查询、增、删、改等操作；
我们先建好一张用户表(user，数据库为test)

创建实体类(User):

 

public class User {
	private int id;
	private String username;
	private String password;

	public User() {
	}

	public User(int id, String username, String password) {
		this.id = id;
		this.username = username;
		this.password = password;
	}

	public int getId() {
		return id;
	}

	public void setId(int id) {
		this.id = id;
	}

	public String getUsername() {
		return username;
	}

	public void setUsername(String username) {
		this.username = username;
	}

	public String getPassword() {
		return password;
	}

	public void setPassword(String password) {
		this.password = password;
	}

	@Override
	public String toString() {
		return "User [id=" + id + ", password=" + password + ", username="
				+ username + "]";
	}

}

/**
 * @author lhy
 * @description 对用户的CRUD相关操作
 */
public class UserDao {
	// 添加用户
	public void add(User u) {
		Connection conn = DBUtil.createConn();
		String sql = "insert into user values(null,?,?)";
		PreparedStatement ps = DBUtil.prepare(conn, sql);
		try {
			ps.setString(1, u.getUsername());
			ps.setString(2, u.getPassword());
			ps.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		DBUtil.close(ps);
		DBUtil.close(conn);
	}

	// 根据Id删除用户
	public void deleteById(int id) {
		Connection conn = DBUtil.createConn();
		String sql = "delete from user where id=?";
		PreparedStatement ps = DBUtil.prepare(conn, sql);
		try {
			ps.setInt(1, id);
			ps.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		DBUtil.close(ps);
		DBUtil.close(conn);
	}

	// 删除用户
	public void delete(User u) {
		deleteById(u.getId());
	}

	// 更新用户
	public void update(User u) {
		Connection conn = DBUtil.createConn();
		String sql = "update user set username=?,password=? where id=?";
		PreparedStatement ps = DBUtil.prepare(conn, sql);
		try {
			ps.setString(1, u.getUsername());
			ps.setString(2, u.getPassword());
			ps.setInt(3, u.getId());
			ps.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		DBUtil.close(ps);
		DBUtil.close(conn);
	}

	// 根据查询用户
	public User loadById(int id) {
		Connection conn = DBUtil.createConn();
		String sql = "select * from user where id=?";
		PreparedStatement ps = DBUtil.prepare(conn, sql);
		User user = null;
		ResultSet rs = null;
		try {
			ps.setInt(1, id);
			rs = ps.executeQuery();
			if (rs.next()) {
				user = new User();
				user.setId(rs.getInt("Id"));
				user.setUsername(rs.getString("username"));
				user.setPassword(rs.getString("password"));
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		DBUtil.close(rs);
		DBUtil.close(ps);
		DBUtil.close(conn);
		return user;
	}

	// 查询所有用户信息
	public List<User> listUser() {
		Connection conn = DBUtil.createConn();
		String sql = "select * from user";
		PreparedStatement ps = DBUtil.prepare(conn, sql);
		List<User> list = new ArrayList<User>();
		ResultSet rs = null;
		try {
			rs = ps.executeQuery();
			while (rs.next()) {
				User user = new User();
				user.setId(rs.getInt("Id"));
				user.setUsername(rs.getString("username"));
				user.setPassword(rs.getString("password"));
				list.add(user);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		DBUtil.close(rs);
		DBUtil.close(ps);
		DBUtil.close(conn);
		return list;
	}
}

客户端(测试类)：

 

 

public class TestUser {
	public static void main(String[] args) {
		User user = new User();
		user.setUsername("张三");
		user.setPassword("123");
		UserDao userDao = new UserDao();
		// userDao.add(user);//添加用户
		// userDao.deleteById(1);// 删除Id为1的用户
		// userDao.update(new User(2, "李四", "1234546"));// 更新Id为2的用户信息
		// System.out.println(userDao.loadById(2)); // 查询Id为2的用户信息
		// 列出所有的用户
		List<User> list = userDao.listUser();
		for (User u : list) {
			System.out.println(u);
		}
	}
}

 

Java的数据库编程比较简单，这里就不再赘述。
结束语：
Javase基础部分就到这了，之后会更新 Java的反射、注解、代理、设计模式、jsp、Struts、Hibernate、Spring等内容。相信学完了Javase基础之后，对后面的学习会更加轻松。