JAVA_JDBC

测试类：
 1 import java.util.ArrayList;
import java.util.List;

/**
 * 创建数据库：
 *     1.加载驱动
 *         Class.forName("org.sqlite.JDBC");
 *     2.通过驱动管理类获得Connection对象 jdbc:sqlite:+数据库的路径
 *         Connection connection = DriverManager.getConnection("jdbc:sqlite:d:/myTest.db");
 *     3.通过Connection对象获得Statement对象
 *         Statement statement = connection.createStatement();
 *    4.通过statement对象执行sql语句,获得结果集
 *        ResultSet rSet = statement.executeQuery("select * from Student");
 * 
 * @author Administrator
 *
 */
/**
 * exc:
 *     通过Java代码实现，创建表，并对其进行增删改查的功能
 * 
 * 注意：需自导入 sqlitejdbc-0.5.4.jar
 * @author Administrator
 *    !!!
 *    如果出现以下错误：Unsupported major.minor version 52.0
 *    解决方法：    修改编译方式，降低javaee ,javase的版本，同时让编译方式和Jdk版本对应。
 *            右击项目 properties或者alt + enter 选择java Complier 选择 Complier compliance level的版本和当前jdk版本对应，
 *            如果是web项目还要降低 jstl 和javaee的版本。
 */
public class Test {
    public static void main(String[] args) {
        TestJDBC tj = new TestJDBC();
        tj.createTable();
        tj.addUser("张三", "男");
        tj.addUser("李四", "女");
        tj.addUser("王五", "男");
        tj.addUser("赵六", "男");
        System.out.println(    "增："+tj.addUser("周七", "女"));
        System.out.println("删："+tj.deleteUser(4));
        System.out.println("改："+tj.updateUser(2, "haha", "不详"));
        List<User> list = tj.getAllUser();
        for (User user : list) {
            System.out.println("查："+user);
        }
        
    }
}

User类：

public class User {
    private String name;
    private int _id;
    private String sex;
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public int getId() {
        return _id;
    }
    public void setId(int id) {
        this._id = id;
    }
    public String getSex() {
        return sex;
    }
    public void setSex(String sex) {
        this.sex = sex;
    }
    @Override
    public String toString() {
        return "User [name=" + name + ", _id=" + _id + ", sex=" + sex + "]";
    }
    
    
}

TestJDBC类

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;


public class TestJDBC {
    Connection con;//数据库一个连接对象
    Statement statement;//执行sql语句
    ResultSet rs;//得到select语句执行的结果集
    
    public Statement getStatement(){
        try {
            //加载驱动
            Class.forName("org.sqlite.JDBC");
            //获得connection对象
            con = DriverManager.getConnection("jdbc:sqlite:d:/mySqlite.db");//没有会自动创建一个数据库
            //得到Statement对象
            statement = con.createStatement();
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return statement;
        
    }
    public void closeConnection(){
        if(con!= null){
            try {
                con.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        if(statement != null){
            try {
                statement.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        
    }
    public void createTable(){
        statement = getStatement();
        try {
            statement.execute("create table if not exists User(_id Integer primary key autoincrement,name varchar(20),sex varchar(20))");
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            closeConnection();
        }
    }
    public boolean addUser(String name,String sex){
        statement = getStatement();
        try {
            //insert into User(name,age) values('张三',18)
            int count = statement.executeUpdate("insert into User(name,sex) values('"+name+"','"+sex+"')");
            if(count>0){
                return true;
            }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            closeConnection();
        }
        return false;
    }
    public boolean deleteUser(int id){
        statement = getStatement();
        try {
            int count = statement.executeUpdate("delete from User where _id = "+id);
            if(count>0)
                return true;
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return false;
    }
    public boolean updateUser(int id,String name,String sex){
        statement = getStatement();
        try {
            int count = statement.executeUpdate("update User set name='"+name+"',sex='"+sex+"'where _id ="+id);
            if(count>0)
                return true;
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return false;
    }
    public List<User> getAllUser(){
        List<User> list = new ArrayList<User>();
        
        statement =  getStatement();
        try {
            rs = statement.executeQuery("select * from User");
            while(rs.next()){
                User user = new User();
                user.setName(rs.getString("name"));
                user.setSex(rs.getString("sex"));
                user.setId(rs.getInt("_id"));
                list.add(user);
            }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            closeConnection();
        }
        
        return list;
        
    }
}