当前位置:编程学习 > JSP >>

java Access数据库连接代码

要连接该数据源,也就是连接数据库教程,首先要建立一个JDBC-ODBC桥接器,最后面会讲,其方法是:

Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");

Class 是Java.lang包中的一个类,通过调用它的静态方法forName就可以建立桥接器。但建立桥接器时可能发生异常,这是我们所不想见到的,因此要捕获这个异常:

try{
 Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
 }
catch(ClassNotFoundException e){异常捕获}

然后就是连接数据库了,这里要用到java.sql包中的Connection类声明一个对象,再用类DriverManager调用它的静态方法getConnection创建这个连接。

Connection con=DriverManager.getConnection("jdbc:odbc:数据源名字","数据源用户名","数据源密码");


try{
      Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
      }
      catch(ClassNotFoundException e){
        System.out.println(""+e);
      }  

   // 下面一句是重点
   String path = this.getClass().getClassLoader().getResource("db1.mdb").getPath().substring(1);

    //db1.mdb为创建的Access数据库文件

       //此数据库文件路径与java文件在同一路径下


   String url="jdbc:odbc:Driver={Microsoft Access Driver (*.mdb)};DBQ="+path;
        Connection conn=DriverManager.getConnection(url);
        Statement st = conn.createStatement();  


 

实例

package com.manager.common;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import com.mchange.v2.c3p0.ComboPooledDataSource;

/**
 * c3p0 的 jdbc连接池
 *
 * @author 森森
 *
 */
public class DBConnectionPool {

    protected DBConnectionPool() {

    }

    private static ComboPooledDataSource ds = null;

    static {
        try {
            ds = new ComboPooledDataSource();
            // 设置jdbc的Driver类
            ds.setDriverClass("sun.jdbc.odbc.JdbcOdbcDriver");
            // 设置jdbc的url
            ds
                    .setJdbcUrl("jdbc:odbc:driver={Microsoft Access Driver (*.mdb)};DBQ=H:/gyt_web/Database/SiteWeaver.mdb");
//            // 设置数据库的登录用户名
//            ds.setUser("admin");
//            // 设置数据库的登录用户名
//            ds.setPassword("admin");
            // 设置连接池的最大连接数
            ds.setMaxPoolSize(200);
            // 设置连接池的最小连接数
            ds.setMinPoolSize(20);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    protected static synchronized Connection getConnection() {
        Connection con = null;
        try {
            con = ds.getConnection();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return con;
    }

    /**
     * 查询通用方法
     *
     * @param sql
     * @param params
     * @return
     */
    public ResultSet query(String sql, Object[] params) {
        Connection conn = null;
        PreparedStatement ps教程tmt = null;
        ResultSet rs = null;

        conn = this.getConnection();
        try {
            pstmt = conn.prepareStatement(sql);
            if (params != null) {
                for (int i = 0; i < params.length; i++) {
                    pstmt.setObject(i + 1, params[i]);
                }
            }
            rs = pstmt.executeQuery();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

        return rs;

    }

    /**
     * 修改 增加 删除通用方法
     *
     * @param sql
     * @param params
     * @return
     */
    public int executeSQL(String sql, Object[] params) {
        Connection conn = null;
        PreparedStatement pstmt = null;
        int result = 0;

        conn = this.getConnection();
        try {
            pstmt = conn.prepareStatement(sql);
            if (params != null) {
                for (int i = 0; i < params.length; i++) {
                    pstmt.setObject(i + 1, params[i]);
                }
            }
            result = pstmt.executeUpdate();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return result;
    }

}


实例

"import java.sql.*;
public class ConnectAccess {
/**
* 初学者请注意:
* 1:先建立一个access文件a1.mdb,并放在D:下;
* 2:在数据库文件a1.mdb中建立一个表Table1;
* 3:为Table1添加一列,并插入至少一条记录;
* 4:本文是一个完整的类,直接拿去运行就可以。
*/

public static void main(String args[]) throws Exception {
ConnectAccess ca=new ConnectAccess();
ca.ConnectAccessFile();
ca.ConnectAccessDataSource();
}
public void ConnectAccessFile() throws Exception
{
Class.forName(""sun.jdbc.odbc.JdbcOdbcDriver"");
/**
* 直接连接access文件。
*/
String dbur1 = ""jdbc:odbc:driver={Microsoft Access Driver (*.mdb)};DBQ=d:a1.mdb"";
Connection conn = DriverManager.getConnection(dbur1, ""username"", ""password"");
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery(""select * from Table1"");
while (rs.next()) {
System.out.println(rs.getString(1));
}
rs.close();
stmt.close();
conn.close();
"

注意

JDBC能完成与一个数据库建立连接,然后向数据库发送SQL语句,再处理数据库返回的结果。

JDBC在设计上和ODBC相似。JDBC和数据库建立连接的一种方式是首先建立起一个JDBC-ODBC桥接器。

首先安装office2000,就有了Access2000,启动Access,建立新数据库mess.mdb,建立包含两个文本型字段name和sex的表,表名为member,随便录入一些字符串到member表中,保存在任意目录下,比如说C盘下。然后打开控制面板 -> 管理工具 -> 数据源 (ODBC),选择"系统DSN",也可以选择"用户DSN"选项卡,系统的DSN对每个用户都适用可避免调试时出现的权限问题,单击“添加”,

点击"完成",弹出的对话框里将"数据源名"一项设为你喜欢的名字,比如redsun。点"选择",找到"C:mess.mdb"文件,如此一个ODBC数据源就配置好了

补充:Jsp教程,Java技巧及代码 
CopyRight © 2012 站长网 编程知识问答 www.zzzyk.com All Rights Reserved
部份技术文章来自网络,