数据库的CRUD

数据库(sql)—-增删查改(CRUD)

• 开始的数据库：

其中四个增删查改的操作

• insert(插入)

     //插入全部
  insert into t_stu (id,name,age) 
  values ('4','wangqiang',28)    
     //插入一部分
  insert into t_stu (name,age) 
  values ('wangqiang',28)

• delete(删除)

  delete 
  from s_stu
  where id=6    

• query(查询)

  select  */列/行
  from t_stu(表)
  where  name='wangwu'

• update(更新)

  update t_stu(表)
  set id=6
  where age=5;

一、查询

查询的sql语句：

String sql="select * from s_stu where name='lisi'";  //写sql语句

完整代码如下：

package CRUDlianxi;
import java.sql.ResultSet;
import java.sql.SQLException;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.Statement;
public class MainTest {
	public static void main(String[] args) throws SQLException {
			
		//1.获得连接对象
		java.sql.Connection conn=JDBC.getConn();
		
		//2.根据连接对象，得到statement
		java.sql.Statement st=conn.createStatement();
		
		//3.执行sql语句，返回ResultSet
		String sql="select * from s_stu where name='lisi'";  //写sql语句
		ResultSet rs=st.executeQuery(sql);	//返回给ResultSet对象   st连接对象去调用Query方法
		
		//4.遍历
		while(rs.next())  //判断是不是有下一个
		{
			int id=rs.getInt("id");
			String name=rs.getString("name");
			int age=rs.getInt("age");
			System.out.println("id="+id+" name="+name+" age="+age);
		}
			
	}
}

查询结果如下：

---

二、修改

　　主要是更改为st调用executeUpdate(sql)方法，结果返回给一个整数rs,判断rs得知结果修改正确与否

//3.执行sql语句，返回ResultSet
String sql="update s_stu set id=22 where age=18";  //写sql语句
int rs=st.executeUpdate(sql);	//返回给ResultSet对象   st连接对象去调用Query方法

//4判断是不是修改正确
if(rs >0 ){
	System.out.println("更新成功");
}
else
{
	System.out.println("更新失败");
}

完整代码如下：

package CRUDlianxi;
import java.sql.ResultSet;
import java.sql.SQLException;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.Statement;
public class MainTest {
	public static void main(String[] args) throws SQLException {
			
		//1.获得连接对象
		java.sql.Connection conn=JDBC.getConn();
		
		//2.根据连接对象，得到statement
		java.sql.Statement st=conn.createStatement();
		
		//3.执行sql语句，返回ResultSet
		String sql="update s_stu set id=22 where age=18";  //写sql语句
		int rs=st.executeUpdate(sql);	//返回给ResultSet对象   st连接对象去调用Query方法
		
		//4判断是不是修改正确
		if(rs >0 ){
			System.out.println("更新成功");
		}
		else
		{
			System.out.println("更新失败");
		}
			
	}
}

修改结果如下：

修改之后数据库的样子：

---

三、删除

　　和修改操作相比只是sql语句不同，调用的方法都相同。

//3.执行sql语句，返回ResultSet
String sql="delete from s_stu where id=22";  //写sql语句		
int result = st.executeUpdate(sql);//返回给ResultSet对象   st连接对象去调用Query方法

//4判断是不是删除正确
if(result >0 ){
	System.out.println("删除成功");
}
else{
	System.out.println("删除失败");
}

完整代码如下：

package CRUDlianxi;
import java.sql.ResultSet;
import java.sql.SQLException;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.Statement;
public class MainTest {
	public static void main(String[] args) throws SQLException {
			
		//1.获得连接对象
		java.sql.Connection conn=JDBC.getConn();
		
		//2.根据连接对象，得到statement
		java.sql.Statement st=conn.createStatement();
		
		//3.执行sql语句，返回ResultSet
		String sql="delete from s_stu where id=22";  //写sql语句		
		int result = st.executeUpdate(sql);//返回给ResultSet对象   st连接对象去调用Query方法
		
		//4判断是不是删除正确
		if(result >0 ){
			System.out.println("删除成功");
		}
		else{
			System.out.println("删除失败");
		}
			
	}
}

删除结果如下：

删除之后数据库的样子：

---

四、插入

　　和修改操作相比只是sql语句不同，调用的方法都相同。

//3.执行sql语句，返回ResultSet
String sql="insert into s_stu (id,name,age) values (66,'wangqiang',28)";  //写sql语句		
int result = st.executeUpdate(sql);//返回给ResultSet对象   st连接对象去调用Query方法

//4判断是不是删除正确	
if(result >0 ){
	System.out.println("添加成功");
}else{
	System.out.println("添加失败");
}

完整代码如下：

package CRUDlianxi;
import java.sql.ResultSet;
import java.sql.SQLException;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.Statement;
public class MainTest {
	public static void main(String[] args) throws SQLException {
			
		//1.获得连接对象
		java.sql.Connection conn=JDBC.getConn();
		
		//2.根据连接对象，得到statement
		java.sql.Statement st=conn.createStatement();
		
		//3.执行sql语句，返回ResultSet
		String sql="insert into s_stu (id,name,age) values (66,'wangqiang',28)";  //写sql语句		
		int result = st.executeUpdate(sql);//返回给ResultSet对象   st连接对象去调用Query方法
		
		//4判断是不是删除正确	
		if(result >0 ){
			System.out.println("添加成功");
		}else{
			System.out.println("添加失败");
		}
			
	}
}

插入结果如下：

插入之后数据库的样子：

---

代码步骤总结：

1. 需要去拷贝JDBC文件内的JDBC类还有properties文件(有url/name/password等)，之后导入mysql和java的jar连接包。

2. 根据类.getConn()方法—>连接对象conn
   java.sql.Connection conn=JDBC.getConn();
3. 根据对象调取createStatement()方法—>关键对象st
   java.sql.Statement st=conn.createStatement();
4. 然后编写sql语句—>关键对象st调用相关方法(SQL)

   String sql="xxxx";  //写sql语句		
   int result = st.executeUpdate(sql);//返回给ResultSet对象   st连接对象去调用Query方法

5. 按查询的话可以遍历输出答案，如果是其他三种就可以让返回int整数判断是不是成功修改。

if(result >0 )
{
    System.out.println("添加成功");
}
else
{    
    System.out.println("添加失败");
}

赏

×

纯属好玩

扫码打赏，你说多少就多少

打开支付宝扫一扫，即可进行扫码打赏哦