JDBC增、删、改

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/myloveprogrmming/article/details/83903633

package p1;

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

class Person{
	@Override
	public String toString() {
		return "Person [id=" + id + ", name=" + name + "]";
	}
	int id;
	String name;
}
public class Text1 {

	public static void main(String[] args) throws ClassNotFoundException, SQLException {
		Class.forName("com.mysql.jdbc.Driver");//获得驱动,实现jdbc功能的mysql
		//jdbc:mysql:// 指jdbc下的mysql协议
		//mysql默认端口号为3306但我安装时改成了3308
		//获得连接
		Connection connection=DriverManager.getConnection("jdbc:mysql://localhost:3308/db4","root", "123456");
		//得到声明
		Statement statement=connection.createStatement();
		//添加
		String insert="insert into person values(4,'钢铁侠');";
		int result=statement.executeUpdate(insert);
		System.out.println(result);//返回值为0表示失败,非0表示成功
		
		String word="select * from person;"; //双引号内为sql语句,其中的;可以写也可以不写
		//只有在查询时用executeQuery方法,增删改用executeUpdate()方法,得到的结果是一个ResultSet类型的对象,它是一个集合
		ResultSet sets=statement.executeQuery(word);
		ArrayList<Person> arr=new ArrayList<>();//将查询到的数据存Peron对象里,对象存集合里,方便使用
		while(sets.next())//和it.hasNext()方法一样,如果存在则返回true
		{
			Person p=new Person();
			p.id=sets.getInt("id");
			p.name=sets.getString("name");
			arr.add(p);
		}
		System.out.println(arr);
	}

}

输出:1
[Person [id=1, name=小明], Person [id=2, name=小红], Person [id=3, name=大岛君], Person [id=4, name=钢铁侠]]

删除

package p1;

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

class Person{
	@Override
	public String toString() {
		return "Person [id=" + id + ", name=" + name + "]";
	}
	int id;
	String name;
}
public class Text1 {

	public static void main(String[] args) throws ClassNotFoundException, SQLException {
		Class.forName("com.mysql.jdbc.Driver");//获得驱动,实现jdbc功能的mysql
		//jdbc:mysql:// 指jdbc下的mysql协议
		//mysql默认端口号为3306但我安装时改成了3308
		//获得连接
		Connection connection=DriverManager.getConnection("jdbc:mysql://localhost:3308/db4","root", "123456");
		//得到声明
		Statement statement=connection.createStatement();
		//删除
		String insert="delete from person where id=1";
		int result=statement.executeUpdate(insert);
		System.out.println(result);//返回值为0表示失败,非0表示成功
		
		String word="select * from person;"; //双引号内为sql语句,其中的;可以写也可以不写
		//只有在查询时用executeQuery方法,增删改用executeUpdate()方法,得到的结果是一个ResultSet类型的对象,它是一个集合
		ResultSet sets=statement.executeQuery(word);
		ArrayList<Person> arr=new ArrayList<>();//将查询到的数据存Peron对象里,对象存集合里,方便使用
		while(sets.next())//和it.hasNext()方法一样,如果存在则返回true
		{
			Person p=new Person();
			p.id=sets.getInt("id");
			p.name=sets.getString("name");
			arr.add(p);
		}
		System.out.println(arr);
	}

}

输出:
1
[Person [id=2, name=小红], Person [id=3, name=大岛君], Person [id=4, name=钢铁侠]]

3修改

package p1;

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

class Person{
	@Override
	public String toString() {
		return "Person [id=" + id + ", name=" + name + "]";
	}
	int id;
	String name;
}
public class Text1 {

	public static void main(String[] args) throws ClassNotFoundException, SQLException {
		Class.forName("com.mysql.jdbc.Driver");//获得驱动,实现jdbc功能的mysql
		//jdbc:mysql:// 指jdbc下的mysql协议
		//mysql默认端口号为3306但我安装时改成了3308
		//获得连接
		Connection connection=DriverManager.getConnection("jdbc:mysql://localhost:3308/db4","root", "123456");
		//得到声明
		Statement statement=connection.createStatement();
		//修改
		String insert="UPDATE person set NAME='呵呵' WHERE id=2;";
		int result=statement.executeUpdate(insert);
		System.out.println(result);//返回值为0表示失败,非0表示成功
		
		String word="select * from person;"; //双引号内为sql语句,其中的;可以写也可以不写
		//只有在查询时用executeQuery方法,增删改用executeUpdate()方法,得到的结果是一个ResultSet类型的对象,它是一个集合
		ResultSet sets=statement.executeQuery(word);
		ArrayList<Person> arr=new ArrayList<>();//将查询到的数据存Peron对象里,对象存集合里,方便使用
		while(sets.next())//和it.hasNext()方法一样,如果存在则返回true
		{
			Person p=new Person();
			p.id=sets.getInt("id");
			p.name=sets.getString("name");
			arr.add(p);
		}
		System.out.println(arr);
	}

}

输出:
1
[Person [id=2, name=呵呵], Person [id=3, name=大岛君], Person [id=4, name=钢铁侠]]
 

猜你喜欢

转载自blog.csdn.net/myloveprogrmming/article/details/83903633