第一次使用SQlite.
如此神奇的数据库...
-----------------来自小马哥的故事
要使用java程序连接SQLite，并与SQLite进行数据存取操作，必须在系统上设置SQLite JDBC驱动程序和安装Java JDK。按照以下步骤进行：
- 从sqlite-jdbc存储库下载最新版本的 ***sqlite-jdbc-(VERSION).jar***。
- 将下载的jar文件添加到类路径。
- 使用java连接到SQLite数据库。
连接到SQLite数据库
打开Eclipse IDE，创建一个JAVA工程：JavaWithSQLite，下载所需的sqlite-jdbc-(VERSION).jar(下载地址： http://bitbucket.org/xerial/sqlite-jdbc/downloads/ 或者 http://mvnrepository.com/artifact/org.xerial/sqlite-jdbc )，并将它放入到项目的类库中。
使用以下代码使用Java编程语言连接到SQLite数据库，首先创建一个类：ConnectSQLite.java，其代码如下所示 -
代码语言：javascript复制package cn.maruifu.sqlite;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class ConnectSQLite {
/**
* Connect to a sample database
*/
public static void connect() {
Connection conn = null;
try {
// db parameters
String url = "jdbc:sqlite:D:/sqlite/java-sqlite.db";
// create a connection to the database
conn = DriverManager.getConnection(url);
System.out.println("Connection to SQLite has been established.");
} catch (SQLException e) {
System.out.println(e.getMessage());
} finally {
try {
if (conn != null) {
conn.close();
}
} catch (SQLException ex) {
System.out.println(ex.getMessage());
}
}
}
/**
* @param args
* the command line arguments
*/
public static void main(String[] args) {
connect();
}
}执行上面代码后，会创建一个文件：D:/sqlite/java-sqlite.db，并与数据库java-sqlite.db连接。
使用java创建数据库
还可以使用java编程语言在SQLite中创建一个新的数据库。假设要使用Java来创建一个名为java_sqlite.db的数据库。创建一个公共类：CreateDB.java并使用以下代码：
代码语言：javascript复制package cn.maruifu.sqlite;
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.DriverManager;
import java.sql.SQLException;
public class CreateDB {
public static void createNewDatabase(String fileName) {
String url = "jdbc:sqlite:" fileName;
try {
Connection conn = DriverManager.getConnection(url);
if (conn != null) {
DatabaseMetaData meta = conn.getMetaData();
System.out.println("The driver name is " meta.getDriverName());
System.out.println("A new database has been created.");
}
} catch (SQLException e) {
System.out.println(e.getMessage());
}
}
public static void main(String[] args) {
createNewDatabase("D:/sqlite/create-db.db");
}
}执行上面代码，得到以下结果 -
代码语言：javascript复制The driver name is SQLiteJDBC
A new database has been created.现在创建一个名为“create-db.db”的新数据库。可以看到对应创建目录有一个文件：create-db.db存在。
使用java创建一个表
假设要通过Java程序在SQLite中创建一个名为tb_emp的表，tb_emp表具有id,name和capacity这三列。首先创建一个Java类：CreateTable.java，并使用以下代码
代码语言：javascript复制package cn.maruifu.sqlite;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class CreateTable {
public static void createNewTable() {
// SQLite connection string
String url = "jdbc:sqlite:D:/sqlite/java-sqlite.db";
// SQL statement for creating a new table
String sql = "CREATE TABLE IF NOT EXISTS employees (n" " id integer PRIMARY KEY,n"
" name text NOT NULL,n" " capacity realn" ");";
try {
Connection conn = DriverManager.getConnection(url);
Statement stmt = conn.createStatement();
stmt.execute(sql);
System.out.println("Create table finished.");
} catch (SQLException e) {
System.out.println(e.getMessage());
}
}
/**
* @param args
* the command line arguments
*/
public static void main(String[] args) {
createNewTable();
}
}执行上面代码，得到以下结果 -
代码语言：javascript复制Create table finished.执行上面代码后，将在java-sqlite.db数据库中创建一个名称为：employees 的表。
向表中插入记录
创建表后，使用以下代码在表中插入一些记录。 创建一个新的Java类：InsertRecords，具有以下代码：
代码语言：javascript复制package cn.maruifu.sqlite;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class InsertRecords {
private Connection connect() {
// SQLite connection string
String url = "jdbc:sqlite:D:/sqlite/java-sqlite.db";
Connection conn = null;
try {
conn = DriverManager.getConnection(url);
} catch (SQLException e) {
System.out.println(e.getMessage());
}
return conn;
}
public void insert(String name, double capacity) {
String sql = "INSERT INTO employees(name, capacity) VALUES(?,?)";
try {
Connection conn = this.connect();
PreparedStatement pstmt = conn.prepareStatement(sql);
pstmt.setString(1, name);
pstmt.setDouble(2, capacity);
pstmt.executeUpdate();
} catch (SQLException e) {
System.out.println(e.getMessage());
}
}
public static void main(String[] args) {
InsertRecords app = new InsertRecords();
// insert three new rows
app.insert("Maxsu", 30000);
app.insert("Minsu", 40000);
app.insert("Miswong", 50000);
System.out.println("Insert data finished.");
}
}现在记录被插入到表中。 可以使用SELECT命令查看它：
!!!表中插入记录 是用客户端navicat 查询.
查询/选择记录
要使用Java程序从表中选择/查询记录，请使用以下代码。 创建一个新的Java类 - SelectRecords.java，使用以下代码 -
代码语言：javascript复制package cn.maruifu.sqlite;
import java.sql.DriverManager;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class SelectRecords {
private Connection connect() {
// SQLite connection string
String url = "jdbc:sqlite:D:/java-sqlite.db";
Connection conn = null;
try {
conn = DriverManager.getConnection(url);
} catch (SQLException e) {
System.out.println(e.getMessage());
}
return conn;
}
public void selectAll() {
String sql = "SELECT * FROM employees";
try {
Connection conn = this.connect();
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery(sql);
// loop through the result set
while (rs.next()) {
System.out.println(rs.getInt("id") "t" rs.getString("name") "t" rs.getDouble("capacity"));
}
} catch (SQLException e) {
System.out.println(e.getMessage());
}
}
/**
* @param args
* the command line arguments
*/
public static void main(String[] args) {
SelectRecords app = new SelectRecords();
app.selectAll();
}
}执行上面代码，得到以下结果 -
本文由 小马哥 创作，采用 知识共享署名4.0 国际许可协议进行许可 本站文章除注明转载/出处外，均为本站原创或翻译，转载前请务必署名 最后编辑时间为: 2017/11/23 09:18
