java用对象对mysql进行更删改查

yzc164

首先注册驱动，驱动注册一边即可，将代码封装在一个类里面

/*我们每次连接数据库都要注册驱动，并且注册驱动只要一次即可，如果用一次注册一次岂不是相当的麻烦，那
* 我们为何不把他写入一个类，只要程序一掉用此类，就自动注册驱动，static{}块是在程序中只要调用此类，
* static块就会自动执行的代码块，
并且只会执行一次*/
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class Util {
static String url="jdbc:mysql://127.0.0.1:3306/mydata";//注册驱动
static String user="root";//输入用户与密码
static String pass="1";

static{//一旦程序调用了此类，此段代码便会自动执行
try {
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

public static Connection getConn() throws SQLException//返回一个Connection对象，方便数据的插入
{
return DriverManager.getConnection(url, user, pass);  
}

public static void free(Statement st,Connection conn) //等sql语句执行完毕，关闭连接
{
if(st!=null)
try {
st.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally{//如果前面抛异常，conn照样可以关闭
if(conn!=null)
try {
conn.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
/*st.close();
conn.close();*/
}
public static void free(ResultSet rs,Statement st,Connection conn)
{
if(rs!=null)
try {
rs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
free(st,conn);
}
}


将mysql里的student表封装成一个对象

//将要插入的数据封装成一个对象，并且生成每个属性的get和set方法

public class Student {
private int id;
private String name;
private int age;
public Student(int id){
this.id=id;
}
public Student(int id,String name,int age)
{
this.id=id;
this.name=name;
this.age=age;
}
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
}


建立一个类用来写mysql的语句
/*此类里面写的是sql语句，当外部调用此类的方法的时候，不用再去写sql语句，
因为内部已经将sql语句写好，不需要知道内部的具体实现*/

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import javax.naming.spi.DirStateFactory.Result;

public class StuDao {
public void insert(Student s)//插入语句
{
try {
Connection conn=Util.getConn();
/*在此用到了一个preparedStatement是Statement的一个子类，它比Statement更方便一些，在Statement的execteUpdate
方法中，传递的参数只能是sql语句，就算是一样的要修改数据不一样而其他一样的几句话也必须将代码全部写出
例如：String sql="insert into student(id,name,age)values(1,zhangsan,11)";
String sql="insert into student(id,name,age)values(2,lisi,12)";
String sql="insert into student(id,name,age)values(3,wangwu,13)";
但是，PreparedStatement使用起来更加方便，它允许传递一个未知量————?,它的setInt等方法有两个参数
第一个是参数的意思是第几个?,第二个参数是修改的值*/
String sql="insert into student(id,name,age)values(?,?,?)";
PreparedStatement st=conn.prepareStatement(sql);
st.setInt(1, s.getId());
st.setString(2, s.getName());
st.setInt(3, s.getAge());
int i=st.executeUpdate();
Util.free(st, conn);

} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void update(Student s)//修改语句
{
try {
Connection conn=Util.getConn();
String sql="update student set name=?,age=? where id=?";
PreparedStatement st=conn.prepareStatement(sql);
st.setString(1, s.getName());
st.setInt(2, s.getAge());
st.setInt(3, s.getId());
int i=st.executeUpdate();
Util.free(st, conn);

} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void delete(Student s){//删除语句
try {
Connection conn = Util.getConn();
String sql="delete from student where id =?";
PreparedStatement st = conn.prepareStatement(sql);
st.setInt(1, s.getId());
int i=st.executeUpdate();
Util.free(st, conn);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void select1(Student s){//查询语句
try {
Connection conn = Util.getConn();
String sql = "select * from student where id=?";
PreparedStatement st = conn.prepareStatement(sql);
st.setInt(1, s.getId());
ResultSet rs = st.executeQuery();
while(rs.next()){
System.out.println(rs.getInt(1)+" "+rs.getString(2)+" "+rs.getInt(3));
}
Util.free(st, conn);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}


测试类
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class TestConnection {

public static void main(String[] args) {
// TODO Auto-generated method stub
Student s=new Student(4);
StuDao dao=new StuDao();
dao.select1(s);
}
}