java 连接数据库

JDBCJava Data Base Connectivity,java数据库连接)是一种用于执行SQL语句的Java API,可以为多种关系数据库提供统一访问,它由一组用Java语言编写的类和接口组成。是Java访问数据库的标准规范

 

JDBC是接口,驱动是接口的实现,没有驱动将无法完成数据库连接,从而不能操作数据库!每个数据库厂商都需要提供自己的驱动,用来连接自己公司的数据库,也就是说驱动一般都由数据库生成厂商提供。

连接数据库步骤

 

1 1.注册驱动.2  告知JVM使用的是哪一个数据库的驱动3 //DriverManager.registerDriver(new Driver());4 //把com.mysql.jdbc.driver这个实现类之间扔到内存里5 //扔到内存之后调用static静态代码块6 //静态代码块中注册驱动7 Class.forName("com.mysql.jdbc.Driver");

 

1 2.获得连接.2  使用JDBC中的类,完成对MySQL数据库的连接 3 //要连接的数据库名字,写死,编码方式 ?characterEncoding=utf-84 String url ="jdbc:mysql://localhost:3306/goods?characterEncoding=utf-8";5 String user ="root";6 String password ="1";7 Connection conn =DriverManager.getConnection(url, user, password);
1 3.获得语句执行平台2  通过连接对象获取对SQL语句的执行者对象3 Statement sta =conn.createStatement();
4.执行sql语句 使用执行者对象,向数据库执行SQL语句 获取到数据库的执行后的结果 //增加语句 /* String str ="insert into sort values(‘3‘,‘文具‘,‘钢笔‘)"; int i =se.executeUpdate(str); System.out.println(i);*/ //修改语句 update 表名 set 要修改的表名 where 条件 /* String str ="update sort set sdesc =‘paike‘ where sid =‘1‘"; int i =se.executeUpdate(str); System.out.println(i);*/ //删除语句 /* String str ="delete from sort where sid =‘7‘"; int i = se.executeUpdate(str); System.out.println(i);*/ //查询语句 String str ="select * from sort"; ResultSet re =se.executeQuery(str); while(re.next()){ System.out.println(re.getInt("sid")+re.getString("sname")+re.getString("sdesc")); }
6.释放资源.(先开的后关) 调用一堆close()方法 rs.close(); sta.close(); conn.close();*/

 封装    重点

 1 这里创建一个新的类 2 package com.orcale.demo; 3  4 import java.sql.Connection; 5 import java.sql.DriverManager; 6 import java.sql.ResultSet; 7 import java.sql.SQLException; 8 import java.sql.Statement; 9 10 public class Demo04 {11 private static Connection conn =null; 设置成全局变量12 static{ 13 try { 14 Class.forName("com.mysql.jdbc.Driver"); 注册程序,然后写传过去参数内容15 String url ="jdbc:mysql://localhost:3306/aaa"; 16 String user = "root";17 String password ="1";18 conn =DriverManager.getConnection(url, user, password); 19 } catch (ClassNotFoundException | SQLException e) { 抛出异常20  e.printStackTrace();21  }22  }23 //获取连接对象24 public static Connection getConnection(){ 25 return conn;26  }27 //关闭数据库28 public static void close(Connection conn,Statement stat,ResultSet re) throws SQLException{29 if(conn!=null){30  conn.close();31  }32 if(stat!=null){33  conn.close();34  }35 if(re!=null){36  re.close();37  }38  }39 public static void close(Connection conn,ResultSet re) throws SQLException{40 if(conn!=null){41  conn.close();42  }43 if(re!=null){44  re.close();45  }46  }47 }
1 Connection conn =Demo04.getConnection(); 调用方法获取2 String sql ="select * from user"; sql语句3 Statement stat =conn.createStatement(); 获取语句执行平台4 ResultSet re =stat.executeQuery(sql); 调用5 while(re.next()){6 System.out.println(re.getString("name")+re.getString("password"));7 }

 

 

 

 

 

 

 

 


相关文章