一.开发步骤
1.注册驱动
Class.forName("com.mysql.jdbc.Driver");
2.获取连接对象(conn)
//获取数据库的地址
String url = "jdbc:mysql//localhost:3306/数据库名";
//获取MySQL用户
String user = "账户";
//获取MySQ密码
String password = "mysql密码";
Connection conn = DriverManager.getConnection(url,user.password);
3.获取执行SQL语句对象
Statement stat = conn.createStatement();
//拼写查询的SQL语句
String sql = "select * from 表名";
4.调用执行者对象方法,,执行SQL语句获取结果集
ResultSet rs = stat.executeQuery(sql);
5.处理结果集
while(rs.next()){
System.out.println(rs.getInt("id")+" "+rs.getString("name")+" "+rs.getDouble("price"));
}
6.关闭资源
rs.close();
sta.close();
conn.close();
二.源代码
package JDBC; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; public class JDBCDemo { public static void main(String[] args) throws ClassNotFoundException, SQLException { //1.注册数据库驱动程序 //DriverManager.registerDriver(new Driver()); Class.forName("com.mysql.jdbc.Driver"); //2.连接数据库对象 String url = "jdbc:mysql://localhost:3306/jdbc_em"; String user = "root"; String password = "123456"; Connection conn = DriverManager.getConnection(url,user,password); System.out.println(conn); //3.获取数据库执行对象 Statement sta = conn.createStatement(); System.out.println(sta); //4.执行sql语句 /*int row = sta.executeUpdate("insert into goods(id,name,price) values(3,'li',14)"); System.out.println(row);*/ //获取执行sql语句 String sql = "select * from goods"; //4.调用执行者对象方法,,执行SQL语句获取结果集 ResultSet rs = sta.executeQuery(sql); //5.处理结果集 while(rs.next()){ System.out.println(rs.getInt("id")+" "+ rs.getString("name")+" "+rs.getDouble("price")); } //6.关闭资源 rs.close(); sta.close(); conn.close(); } } |
运行结果: