/**
*四大参数
*driveClassName:com.mysql.jdbc.Driver
*url:jdbc:mysql://localhost:3306/test
*username:root
*password:lj
*/
步骤:
1.连接数据库驱动
Class.forName("com.mysql.jdbc.Driver");
2.建立数据库连接,利用三个参数连接数据库
Connection conn=DriverManager.getConnection
("jdbc:mysql://localhost:3306/test","root","lj");
3.新建sql语句传入PreparedStatement,得到PreparedStatement,用这对象向数据库发送sql语句
String sql="select * from qiu";
PreparedStatement pst=conn.prepareStatement(sql);
4.获取结果集
ResultSet rs=pst.executeQuery();
5.利用结果集对象,输出到页面上
while(rs.next()){
System.out.println(rs.getInt("id")+"\t"+rs.getString("name")+"\t"+rs.getString("sex"));
}
6.关闭资源
if(conn == null)conn.close();
if(pst == null)pst.close();
if(rs == null)rs.close();
整体代码:
package com.theme.demo1;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class Demo2 {
static Connection conn=null;
static PreparedStatement pst=null;
static ResultSet rs=null;
public static void main(String arg[]) throws ClassNotFoundException, SQLException{
//连接数据库驱动,抛出一个连接驱动异常
Class.forName("com.mysql.jdbc.Driver");
//通过三个参数连接数据库,抛出一个连接数据库异常
conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/test","root","lj");
//增加数据
//String sql= "insert into qiu(name,sex) values(?,?)";
//更新数据
//String sql="update qiu set name='小明' where id=1";
//删除数据
//String sql="delete from qiu where name=?";
//得到PreparedStatement,用这对象向数据库发送sql语句
//String sql="select * from qiu";
//pst=conn.prepareStatement(sql);
//执行sql语句,获取结果集
//rs=pst.executeQuery();
//依次设置?占位符的值
//pst.setObject(1, "小芳");
//pst.setObject(2, "女");
//pst.setObject(1,"小芳");
//System.out.println("id"+"\t"+"name"+"\t"+"sex");
//利用结果集对象,输出到页面上
/*
while(rs.next()){
System.out.println(rs.getInt("id")+"\t"+rs.getString("name")+"\t"+rs.getString("sex"));
}
*/
//增删改都用这个方法就行了
pst.execute();
if(conn != null)conn.close();
if(pst != null)pst.close();
//if(rs != null)rs.close();
}
}
*查询要解析结果集,关闭结果集,用到pst的executeQuery()方法
网友评论