JDBC进行增删改查代码,Java代码库,德仔网

代码语言
代码分类
【Java】 JDBC进行增删改查
作者:海王 / 发布于2014/6/9/ 749
使用JDBC进行增删改查

	package dao.demo;

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

	public class Test {
	/**
	 * ************ 使用JDBC连接数据库 数据库:mysql 地址:localhost:3306 用户root 密码 root 表
	 * person
	 **************
	 */
	@org.junit.Test
	public void testConn() throws Exception {
	 // 1 注册驱动
	 Class.forName("com.mysql.jdbc.Driver");
	 // 2获得链接
	 Connection conn = DriverManager.getConnection(
	 "jdbc:mysql://localhost:3306/JDBCDEMO", "root", "root");
	 // 3创建语句执行者
	 Statement st = conn.createStatement();
	 // 4执行查询sql语句，并返回结果集
	 ResultSet rs = st.executeQuery("select * from person");
	 // 5处理结果，结果集遍历
	 while (rs.next()) {
	 String id = rs.getString("id"); // rs.getString(1)
	 String name = rs.getString("name");
	 String password = rs.getString("password");
	 System.out.println(id + " : " + name + " : " + password);
	 }
	 // 6释放资源
	 rs.close();
	 st.close();
	 conn.close();
	}
	 /**
	 * ************
	 * 使用JDBC向数据库插入数据
	 **************
	 */
	@org.junit.Test
	public void save() throws Exception {
	 // 1注册驱动
	 Class.forName("com.mysql.jdbc.Driver");
	 // 2获得链接
	 Connection conn = DriverManager.getConnection(
	 "jdbc:mysql://localhost:3306/JDBCDEMO", "root", "root");
	 // 3获得语句执行者
	 Statement st = conn.createStatement();
	 // 4执行语句
	 int r = st
	 .executeUpdate("insert into person(id,name,password) values(3,'王五','333')");

	 // 5处理结果
	 System.out.println("save -->" + r);

	 // 6释放资源
	 st.close();
	 conn.close();

	}
	/**
	 * ************
	 *更新数据
	 **************
	 */
	@org.junit.Test
	public void update()throws Exception{
	 //更新 update
	
	 //1注册驱动
	 Class.forName("com.mysql.jdbc.Driver");
	 //2获得链接
	 Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/JDBCDEMO", "root", "root");
	 //3获得语句执行者
	 Statement st = conn.createStatement();
	 //4执行语句
	 int r = st.executeUpdate("update person set password = '1110' where id = 1");
	
	 //5处理结果
	 System.out.println("update --> " + r);
	
	 //6释放资源
	 st.close();
	 conn.close();
	}
	@org.junit.Test
	public void findById()throws Exception{
	 //查询
	
	 //1注册驱动
	 Class.forName("com.mysql.jdbc.Driver");
	 //2获得链接
	 Connection conn =DriverManager.getConnection("jdbc:mysql://localhost:3306/JDBCDEMO", "root", "root");
	 //3获得语句执行者
	 Statement st = conn.createStatement();
	 //4执行语句
	 ResultSet rs = st.executeQuery("select * from person where id = 2 ");
	
	 //5处理结果
	 if(rs.next()){ //while(rs.next) {
	 String id = rs.getString("id");
	 String name = rs.getString("name");
	 String password = rs.getString("password");
	 System.out.println("selectbyId --> " + id + " : " + " : " + name + " : " + password);
	 } else {
	 System.out.println("没有结果");
	 }
	
	 //6释放资源
	 rs.close();
	 st.close();
	 conn.close();
	
	
	
	}
	
	@org.junit.Test
	public void delete()throws Exception{
	 //删除delete
	
	 //1注册驱动
	 Class.forName("com.mysql.jdbc.Driver");
	 //2获得链接
	 Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/JDBCDEMO", "root", "root");
	 //3获得语句执行者
	 Statement st = conn.createStatement();
	 //4执行语句
	 int r = st.executeUpdate("delete from person where id =3 ");
	
	 //5处理结果
	 System.out.println("delete --> " + r);
	
	 //6释放资源
	 st.close();
	 conn.close();
	}
	
	}
试试其它关键字
　JDBC　　增删改查　
同语言下
可能有用的
海王贡献的其它代码(5)