Java操作SQLite数据库

sqlite-jdbc 仓库地址：

https://bitbucket.org/xerial/sqlite-jdbc

sqlite-jdbc.jar

1、下载地址

https://bitbucket.org/xerial/sqlite-jdbc/downloads/

2、示例代码

package com.mouday;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;


public class App 
{
    public static void main( String[] args ) throws ClassNotFoundException, SQLException {
        Class.forName("org.sqlite.JDBC");
        Connection connection = DriverManager.getConnection("jdbc:sqlite:test.db");
        System.out.println( "Hello World!" );
    }
}

3、运行测试

javac com.mouday.App

# Mac or Linux
java  -classpath ".:sqlite-jdbc-3.7.2.jar" com.mouday.App

# Windows
java  -classpath ".;sqlite-jdbc-3.7.2.jar" com.mouday.App

使用Maven

依赖

<dependencies>
    <dependency>
      <groupId>org.xerial</groupId>
      <artifactId>sqlite-jdbc</artifactId>
      <version>3.7.2</version>
    </dependency>
</dependencies>

SQLite的存储类

1. 1. 
      
2. NULL
3. INTEGER 带符号的整数
4. REAL 浮点值
5. TEXT 文本字符串
6. BLOB
   1. 
      

定义数据结构

package com.mouday;

public class Person {
    private int id;
    private String name;

    public Person(int id, String name) {
        this.id = id;
        this.name = name;
    }

    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;
    }
}

CURD

package com.mouday;

import java.sql.*;
import java.util.ArrayList;
import java.util.List;

public class App {
    public static void main(String[] args) throws ClassNotFoundException {
        // 加载驱动
        Class.forName("org.sqlite.JDBC");

        Connection connection = null;
        try {

            // 获取连接
            connection = DriverManager.getConnection("jdbc:sqlite:test.db");

            Statement statement = connection.createStatement();

            // 建表
            statement.executeUpdate("drop table if exists person");
            statement.executeUpdate("create table person (id integer , name text)");

            // 插入数据
            statement.executeUpdate("insert into person(id, name) values(1, '刘备')");
            statement.executeUpdate("insert into person(id, name) values(2, '关羽')");
            statement.executeUpdate("insert into person(id, name) values(3, '张飞')");

            // 更新数据
            statement.executeUpdate("update person set name='诸葛亮' where id = 2");

            // 删除数据
            statement.executeUpdate("delete from person where id = 3");


            // 批处理
            String  sql = "insert into person(id, name) values(?, ?)";
            PreparedStatement preparedStatement = connection.prepareStatement(sql);

            List<Person> list = new ArrayList<>();
            list.add(new Person(4, "Tom"));
            list.add(new Person(5, "曹操"));
            list.add(new Person(6, "刘备"));

            for(Person person: list){
                preparedStatement.setInt(1, person.getId());
                preparedStatement.setString(2, person.getName());
                preparedStatement.addBatch();
            }

            preparedStatement.executeBatch();
            preparedStatement.close();

            // 查询数据
            ResultSet resultSet = statement.executeQuery("select * from person");
            while (resultSet.next()){
                System.out.println(resultSet.getInt("id"));
                System.out.println(resultSet.getString("name"));
            }

            statement.close();

        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try{
                if( connection != null){
                    connection.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}