JDBC 数据库增删改查 入门级示例

【实例截图】

【核心代码】

package com.xyyz.jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

import com.xyyz.utils.JDBCUtils;

public class JDBCDemo {

	public static void main(String[] args) throws Exception {
		query();
		insert();
		query();
		update();
		query();
		delete();
		query();
	}

	/**
	 * 查询代码
	 * 
	 * @throws Exception
	 */
	public static void query() throws Exception {
		Connection connection = JDBCUtils.getConnection();
		// 获取数据库连接
		String sql = "select * from jdbctestdata";
		// 获取预编译对象
		PreparedStatement prepareStatement = connection.prepareStatement(sql);
		// 执行sql语句
		ResultSet resultSet = prepareStatement.executeQuery();
		// 遍历打印sql语句
		while (resultSet.next()) {
			System.out.println(resultSet.getInt(1)   "--"   resultSet.getString(2));
		}
		// 关闭释放资源
		JDBCUtils.closeAll(resultSet, prepareStatement, connection);
	}

	/**
	 * 插入数据
	 */
	public static void insert() throws Exception {
		// 获取数据库连接
		Connection connection = JDBCUtils.getConnection();
		String sql = "insert into jdbctestdata value(?,?,?)";
		// 获取预编译对象
		PreparedStatement prepare = connection.prepareStatement(sql);
		prepare.setString(1, "6");
		prepare.setString(2, "小白");
		prepare.setString(3, "30");
		int i = prepare.executeUpdate();
		System.out.println("i="   i);
		// 关闭释放资源
		JDBCUtils.closeAll(null, prepare, connection);
	}

	/**
	 * 更新数据
	 */
	public static void update() throws Exception {
		
		// 获取数据库连接
		Connection connection = JDBCUtils.getConnection();
		String sql = "update jdbctestdata set name=? , age=? where id=?";
		// 获取预编译对象
		PreparedStatement prepare = connection.prepareStatement(sql);
		prepare.setString(1, "小红");
		prepare.setString(2, "20");
		prepare.setString(3, "6");
		int i = prepare.executeUpdate();
		System.out.println("i="   i);
		// 执行sql语句
		JDBCUtils.closeAll(null, prepare, connection);
	}

	/**
	 * 删除数据
	 */
	public static void delete() throws Exception {
		// 获取数据库连接
		Connection connection = JDBCUtils.getConnection();
		String sql = "delete from jdbctestdata where id = ?";
		// 获取预编译对象
		PreparedStatement prepare = connection.prepareStatement(sql);
		prepare.setString(1, "6");
		int i = prepare.executeUpdate();
		System.out.println("i="   i);
		// 执行sql语句
		JDBCUtils.closeAll(null, prepare, connection);
	}

}