Java操作Sqlite数据库-jdbc连接

admin

Java操作Sqlite数据库步骤：

1. 导入Sqlite jdbc

本文使用sqlite-jdbc-3.7.2.jar,下载地址 http://pan.baidu.com/s/1kVHAGdD

2. 编写jdbc连接代码

1. public class OpSqliteDB {
   
2.    
   
3.     private static final String Class_Name = "org.sqlite.JDBC";
   
4.     private static final String DB_URL = "jdbc:sqlite:F:\\xxxdatabase.db";
   
5. 
   
6.     public static void main(String args[]) {
   
7.         // load the sqlite-JDBC driver using the current class loader
   
8.         Connection connection = null;
   
9.         try {
   
10.             connection = createConnection();
    
11.             func1(connection);
    
12.             System.out.println("Success!");
    
13.         }  catch (SQLException e) {
    
14.             System.err.println(e.getMessage());
    
15.         } catch(Exception e) {
    
16.             e.printStackTrace();
    
17.         } finally{
    
18.             try {
    
19.                 if (connection != null)
    
20.                     connection.close();
    
21.             } catch (SQLException e) {
    
22.                 // connection close failed.
    
23.                 System.err.println(e);
    
24.             }
    
25.         }
    
26.     }
    
27.    
    
28.     // 创建Sqlite数据库连接
    
29.     public static Connection createConnection() throws SQLException, ClassNotFoundException {
    
30.         Class.forName(Class_Name);
    
31.         return DriverManager.getConnection(DB_URL);
    
32.     }
    
33. 
    
34.     public static void func1(Connection connection) throws SQLException {
    
35.         Statement statement = connection.createStatement();
    
36.         Statement statement1 = connection.createStatement();
    
37.         statement.setQueryTimeout(30); // set timeout to 30 sec.
    
38.         // 执行查询语句
    
39.         ResultSet rs = statement.executeQuery("select * from table_name1");
    
40.         while (rs.next()) {
    
41.             String col1 = rs.getString("col1_name");
    
42.             String col2 = rs.getString("col2_name");
    
43.             System.out.println("col1 = " + col1 + "  col2 = " + col2);
    
44.             
    
45.             System.out.println(location);
    
46.             // 执行插入语句操作
    
47.             statement1.executeUpdate("insert into table_name2(col2) values('" + col2_value + "')");
    
48.             // 执行更新语句
    
49.             statement1.executeUpdate("update table_name2 set 字段名1=" +  字段值1 + " where 字段名2='" +  字段值2 + "'");
    
50.         }
    
51.     }

复制代码