返回
网站建设知识
MySQL第六天---Java与数据库的连接(简单的增、删、改、查）Statement缺陷和子类PreparedStatement
2025-07-22 10:01  点击:0

这里补一下，java连接到数据库的模板。

有四个步骤：1.加载连接器

2.声明连接哪台主机的数据库,同时指定编码

3.建立连接

4.对数据库中的内容进行操作

DBHelloWorld.java

package cn.hncu;import java.sql.Connection;import java.sql.DriverManager;import java.sql.ResultSet;import java.sql.Statement;//import com.mysql.jdbc.Driver; Driver类补全即可得到完成类名,用于下面的类反射public class DBHelloWorld {public static void main(String[] args) throws Exception {//1.加载连接器Class.forName("com.mysql.jdbc.Driver");//驱动//2.声明连接哪台主机的数据库,同时指定编码String url="jdbc:mysql://127.0.0.1:3306/abc?useUnicode=true&characterEncoding=utf-8";//3.建立连接Connection con= DriverManager .getConnection(url, "hncu", "1234");//4.对数据库中的内容进行操作Statement st=con.createStatement();//创建语句对象StatementString sql="insert into stud values(13,'Eclipse',60,91.2);";//增//sql="update stud set sname='MyEclipse' where sid=13";改//sql="delete from stud where sid=13";//删//boolean boo=st.execute(sql);//System.out.println(boo);//查询sql="select * from stud;";ResultSet rs=st.executeQuery(sql);while(rs.next()){//第一个在数据项之上,要移下来一个。表示下一项是不是数据项，若不是则返回falseint id=rs.getInt("sid");int id2=rs.getInt(1);//两种方法都行,一个用字段名,一个用字段序号(从1开始)String name=rs.getString(2);int age=rs.getInt("sage");double score=rs.getDouble(4);System.out.println("id="+id+",id2="+id2+",name="+name+",age="+age+",score="+score);}}}

为了以后写代码的简洁性，和减少内存开销这里对连接数据库做了工厂类，模仿Hibernate做了配置文件

jdbc.properties

MySQLdriver=com.mysql.jdbc.Driverurl=jdbc:mysql://127.0.0.1:3306/hncu?useUnicode=true&characterEncoding=utf-8username=hncupassword=1234##Oracle#driver=oracle.jdbc.driver.OracleDriver#url=jdbc:oracle:thin:@127.0.0.1:1521:orcl#username=scott#password=tiger


ConnFactory.java

package cn.hncu.pubs;import java.io.IOException;import java.sql.Connection;import java.sql.DriverManager;import java.util.Properties;public class ConnFactory {private static Connection con;private ConnFactory(){}static{//为了确保每次拿的connection都一样，采用单例try {Properties p=new Properties();//放在src目录下                                                                                   p.load(ConnFactory.class.getClassLoader().getResourceAsStream("jdbc.properties"));//读取classpath下的资源文件String driver=p.getProperty("driver");String url=p.getProperty("url");String username=p.getProperty("username");String password=p.getProperty("password");Class.forName("com.mysql.jdbc.Driver");con=DriverManager.getConnection(url, username, password);} catch (Exception e) {e.printStackTrace();}}public static Connection getConn(){return con;}}

JdbcDemo.java

package cn.hncu;import java.sql.Connection;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;import java.util.Scanner;import java.util.UUID;import org.junit.Test;import org.junit.runners.ParentRunner;import cn.hncu.pubs.ConnFactory;public class JdbcDemo {//查@Testpublic void readDemo(){Connection con=null;try {Class.forName("com.mysql.jdbc.Driver");//驱动----jdbc4.0开始可省略//hibernate框架不能省String url="jdbc:mysql://127.0.0.1:3306/hncu?useUnicode=true&characterEncoding=utf-8";//建数据库的时候指定编码,java连接的时候也指定编码，两者一致，只要不是mysql故意改动编码，都不会乱码con=DriverManager.getConnection(url,"hncu","1234");Statement st=con.createStatement();ResultSet rs=st.executeQuery("select * from person2");//该方法专用于查询while(rs.next()){Object id0=rs.getObject("id");//若不知字段类型是什么，可用Object类型去接String id=rs.getString(1);String name=rs.getString("name");String sex=rs.getString(3);if(sex.equals("1")){sex="男";}else if(sex.equals("0")){sex="女";}else{sex="不详";}System.out.println("id0-"+id0+",id-"+id+",name-"+name+",sex-"+sex);}} catch (Exception e) {e.printStackTrace();}finally{if(con!=null){try {con.close();} catch (SQLException e) {e.printStackTrace();}}}}//增@Testpublic void saveDemo(){try {Class.forName("com.mysql.jdbc.Driver");String url="jdbc:mysql://127.0.0.1:3306/hncu?useUnicode=true&characterEncoding=utf-8";//建数据库的时候指定编码,java连接的时候也指定编码，两者一致，只要不是mysql故意改动编码，都不会乱码Connection con=DriverManager.getConnection(url,"hncu","1234");Statement st=con.createStatement();//增//String sql="insert into person2 values('P03','王晓明','0')";// String id=UUID.randomUUID().toString().replace("-", "");// Scanner sc=new Scanner(System.in);// System.out.println("请输入姓名:");// String name=sc.nextLine();// String sql="insert into person2 values('"+id+"','"+name+"','0')";//改 UPDATE person2 SET NAME=ConCAT(NAME,'x');//String sql="update person2 set name=concat(name,'y')";//删String sex="1";String sql="delete from person2 where sex='"+sex+"'";int rows=st.executeUpdate(sql);System.out.println(rows+" row(s) affected");con.close();} catch (Exception e) {e.printStackTrace();}}@Testpublic void saveDemo2(){try {Class.forName("com.mysql.jdbc.Driver");String url="jdbc:mysql://127.0.0.1:3306/hncu?useUnicode=true&characterEncoding=utf-8";//建数据库的时候指定编码,java连接的时候也指定编码，两者一致，只要不是mysql故意改动编码，都不会乱码Connection con=DriverManager.getConnection(url,"hncu","1234");Statement st=con.createStatement();//增//String sql="insert into person2 values('P03','王晓明','0')";String id=UUID.randomUUID().toString().replace("-", "");Scanner sc=new Scanner(System.in);System.out.println("请输入姓名:");String name=sc.nextLine();String sql="insert into person2 values('"+id+"','"+name+"','1')";//改 UPDATE person2 SET NAME=ConCAT(NAME,'x');//String sql="update person2 set name=concat(name,'y')";



//删
// String sex="1";
// String sql="delete from person2 where sex='"+sex+"'";


int rows=st.executeUpdate(sql);System.out.println(rows+" row(s) affected");con.close();} catch (Exception e) {e.printStackTrace();}}@Testpublic void resultSetDemo(){Connection con=ConnFactory.getConn();try {Statement st=con.createStatement();String sql="select * from book";ResultSet rs=st.executeQuery(sql);while(rs.next()){Integer id=rs.getInt(1);String name=rs.getString(2);Double price=rs.getDouble(3);String birth=rs.getDate(4)+" "+rs.getTime(4);//数据库中，birth的类型是DateTime，在java中读取时日期和时间字段是分开读的，从同一个字段用两种方法分别读取日期和时间System.out.println(id+","+name+","+price+","+birth);}} catch (SQLException e) {e.printStackTrace();}finally{try {con.close();} catch (SQLException e) {e.printStackTrace();}}}


//Statement缺陷1：----当用户输入特殊字符，如name为li'ming时会挂掉// 解决办法：用SQL转义字符 单引号 ' 或者斜杠 \ 加在特殊字符前面----用java遍历用户信息，在特殊字符前面加转义字符@Testpublic void reg(){Connection con=ConnFactory.getConn();Scanner sc=new Scanner(System.in);System.out.println("请输入id: ");String id=sc.nextLine();System.out.println("请输入用户名： ");String name=sc.nextLine();try {Statement st=con.createStatement();//insert into stud(id,name) values('5','Rose');String sql="insert into stud(id,name) values('"+id+"','"+name+"') ";System.out.println("sql---->"+sql);int rs=st.executeUpdate(sql);System.out.println(rs+" row(s) affected");con.close();} catch (Exception e) {e.printStackTrace();}}//Statement缺陷2：----黑客登录，在输入name时，输： aa' or 'a'='a' 就是把那个where字句判断真假给破坏掉@Testpublic void login(){Connection con=ConnFactory.getConn();Scanner sc=new Scanner(System.in);System.out.println("请输入id: ");String id = sc.nextLine();System.out.println("请输入用户名： ");String name = sc.nextLine();try {Statement st = con.createStatement();//假定id和name在数据库中存在就代表登录成功//insert into stud(id,name) values('5','Rose');String sql = "select count(*) from stud where id='" + id+ "' and name='" + name + "' ";System.out.println("sql---->" + sql);ResultSet rs = st.executeQuery(sql);rs.next();int a = rs.getInt(1);System.out.println("count值为："+a);if (a <= 0) {System.out.println("登录失败!");return;}System.out.println("登录成功!");//con.close();} catch (Exception e) {e.printStackTrace();}}//学习PreparedStatement:它是Statement的子类，帮助Statement在执行前先处理用户的信息@Testpublic void login2(){Connection con=ConnFactory.getConn();Scanner sc=new Scanner(System.in);System.out.println("请输入id: ");String id = sc.nextLine();System.out.println("请输入用户名： ");String name = sc.nextLine();try {//利用PreparedStatement进行预处理sql语句String sql = "select count(*) from stud where id=? and name=? ";//构造sql语句时，在需要插入用户输入的地方用占位符 ?号PreparedStatement pst = con.prepareStatement(sql);//为各个占位符设置参数值pst.setString(1, id);//第一个占位符pst.setString(2, name);ResultSet rs = pst.executeQuery();//注意：此处不要带参数(sql)rs.next();int a = rs.getInt(1);System.out.println("count值为："+a);if (a <= 0) {System.out.println("登录失败!");return;}System.out.println("登录成功!");//con.close();} catch (Exception e) {e.printStackTrace();}}//学习PreparedStatement@Testpublic void reg2(){Connection con=ConnFactory.getConn();Scanner sc=new Scanner(System.in);System.out.println("请输入id: ");String id=sc.nextLine();System.out.println("请输入用户名： ");String name=sc.nextLine();try {//insert into stud(id,name) values('5','Rose');String sql="insert into stud(id,name) values(?,?) ";PreparedStatement pst=con.prepareStatement(sql);pst.setString(1, id);pst.setString(2, name);int rs=pst.executeUpdate();System.out.println(rs+" row(s) affected");con.close();} catch (Exception e) {e.printStackTrace();}}//综上 ，为考虑系统健壮性，我们以后开发时，如果sql语句需要用用户输入构造时，要用PreparedStatement来实现。如果不需要，即sql语句是写死的，用Statement即可}


Statement缺陷：1.遇到特殊字符挂掉了

2.容易被黑掉

我这里的id和name并没有和数据库中的匹配，但是依然登录了

用PreparedStatement修补后就可以了