java如何访问数据库

java如何访问数据库,第1张

Java可以使用JDBC访问数据库,也可以使用各类ORM框架访问数据库,但这些框架最终还是通过JDBC访问数据库,它们只是封装了数据库 *** 作,而使得开发者可以减少这部分消耗。因此,本文只讲解JDBC访问方式。

JDBC访问一般分为如下流程:

1、加载JDBC驱动程序:

在连接数据库之前,首先要加载想要连接的数据库的驱动到JVM(Java虚拟机),

这通过java.lang.Class类的静态方法forName(String className)实现。

例如:

try{

//加载MySql的驱动类

Class.forName("com.mysql.jdbc.Driver")

}catch(ClassNotFoundException e){

System.out.println("找不到驱动程序类 ,加载驱动失败!")

e.printStackTrace()

}

成功加载后,会将Driver类的实例注册到DriverManager类中。

2、提供JDBC连接的URL

•连接URL定义了连接数据库时的协议、子协议、数据源标识。

•书写形式:协议:子协议:数据源标识

协议:在JDBC中总是以jdbc开始

子协议:是桥连接的驱动程序或是数据库管理系统名称。

数据源标识:标记找到数据库来源的地址与连接端口。

例如:(MySql的连接URL)

jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=gbk

useUnicode=true:表示使用Unicode字符集。如果characterEncoding设置为

gb2312或GBK,本参数必须设置为true 。characterEncoding=gbk:字符编码方式。

3、创建数据库的连接

•要连接数据库,需要向java.sql.DriverManager请求并获得Connection对象,该对象就代表一个数据库的连接。

•使用DriverManager的getConnectin(String url,String username,String password )方法传入指定的欲连接的数据库的路径、数据库的用户名和密码来获得。

例如:

//连接MySql数据库,用户名和密码都是root

String url = "jdbc:mysql://localhost:3306/test"

String username = "root"

String password = "root"

try{

Connection con =

DriverManager.getConnection(url , username , password )

}catch(SQLException se){

System.out.println("数据库连接失败!")

se.printStackTrace()

}

4、创建一个Statement

•要执行SQL语句,必须获得java.sql.Statement实例,Statement实例分为以下3种类型:

1、执行静态SQL语句。通常通过Statement实例实现。

2、执行动态SQL语句。通常通过PreparedStatement实例实现。

3、执行数据库存储过程。通常通过CallableStatement实例实现。

具体的实现方式:

Statement stmt = con.createStatement()

PreparedStatement pstmt = con.prepareStatement(sql)

CallableStatement cstmt = con.prepareCall("{CALL demoSp(? , ?)}")

5、执行SQL语句

Statement接口提供了三种执行SQL语句的方法:executeQuery 、executeUpdate和execute

1、ResultSet executeQuery(String sqlString):执行查询数据库的SQL语句,返回一个结果集(ResultSet)对象。

2、int executeUpdate(String sqlString):用于执行INSERT、UPDATE或DELETE语句以及SQL DDL语句,如:CREATE TABLE和DROP TABLE等

3、execute(sqlString):用于执行返回多个结果集、多个更新计数或二者组合的语句。

具体实现的代码:

ResultSet rs = stmt.executeQuery("SELECT * FROM ...")

int rows = stmt.executeUpdate("INSERT INTO ...")

boolean flag = stmt.execute(String sql)

6、处理结果

两种情况:

1、执行更新返回的是本次 *** 作影响到的记录数。

2、执行查询返回的结果是一个ResultSet对象。

•ResultSet包含符合SQL语句中条件的所有行,并且它通过一套get方法提供了对这些行中数据的访问。

•使用结果集(ResultSet)对象的访问方法获取数据:

while(rs.next()){

String name = rs.getString("name")

String pass = rs.getString(1)// 此方法比较高效(列是从左到右编号的,并且从列1开始)

}

7、关闭JDBC对象

*** 作完成以后要把所有使用的JDBC对象全都关闭,以释放JDBC资源,关闭顺序和声明顺序相反:

1、关闭记录集

2、关闭声明

3、关闭连接对象

if(rs != null){ // 关闭记录集

try{

rs.close()

}catch(SQLException e){

e.printStackTrace()

}

}

if(stmt != null){ // 关闭声明

try{

stmt.close()

}catch(SQLException e){

e.printStackTrace()

}

}

if(conn != null){ // 关闭连接对象

try{

conn.close()

}catch(SQLException e){

e.printStackTrace()

}

}

一、使用工具:java语言、Myeclipse。二、 *** 作步骤:1、第一步:加载MySQL的JDBC的驱动2、第二步:创建与MySQL数据库的连接类的实例3、第三步:获取连接类实例con,用con创建Statement对象类实例sql_statement4、第四步:执行查询,用Resu

JDBC是java数据库连接技术的简称,它提供了连接各种数据库的能力,这便使程序的可维护性和可扩展性大大的提高了.JDBC连接数据库常见的驱动方式有两种,一种是jdbc-odbc即桥连另外一种是纯java驱动.一般在做java开发的时候用第二种.so前一种我就不说了,纯java驱动方式连接步骤如下:

1.先把一个jdbc的jar包导入到项目(用MyEclipse开发)的lib中.

2.代码如下:

[c-sharp] view plain copy

import java.sql.*

/**

* 连接数据库帮助类

* @author Administrator

*

*/

public class BaseDao {

private static final String DRIVER="com.microsoft.sqlserver.jdbc.SQLServerDriver"

private static final String URL = "jdbc:sqlserver://localhost:1433DatabaseName=LibraryManageSystem"

private static final String USERNAME="sa"

private static final String PASSWORD="sa"

/**

* 连接数据库

* @return 数据库连接对象

* @throws ClassNotFoundException

* @throws SQLException

*/

public Connection getConn()throws ClassNotFoundException,SQLException{

Class.forName(DRIVER)

Connection conn = DriverManager.getConnection(URL,USERNAME,PASSWORD)

return conn

}

/**

* 释放资源

* @param conn

* @param pstmt

* @param rs

* @throws SQLException

*/

public void closeAll(Connection conn,PreparedStatement pstmt,ResultSet rs)throws SQLException{

if(rs!=null){

rs.close()

}

if(pstmt!=null){

pstmt.close()

}

if(conn!=null){

conn.close()

}

}

/**

* 执行SQL语句,可以进行增、删、改的 *** 作

* @param sql

* @return 影响条数

* @throws ClassNotFoundException

* @throws SQLException

*/

public int executeSQL(String sql)throws ClassNotFoundException,SQLException{

Connection conn = this.getConn()

PreparedStatement pstmt = conn.prepareStatement(sql)

int number = pstmt.executeUpdate()

this.closeAll(conn, pstmt, null)

return number

}

}

从代码知道首先吧jdbc驱动类装载java虚拟机中,即Class.forName(DRIVER)其次加载驱动并建立于数据库的连接Connection conn = DriverManager.getConnection(URL,USERNAME,PASSWORD)然后发送SQL语句并的到结果集.之后处理结果,最后要关闭数据库的连接,释放资源.当然我说的这样连接数据库的方式使用的软件是sql和MyEclipse.

使用配置文件来连接数据库,当然这样的连接需要进行一些配置.其实这样的连接用专业术语来说就是连接池,连接池是负责分配管理和释放数据库连接.它允许用用程序重复使用一个现有的数据库连接不再重复建立连接.释放空闲时间超过最大空闲时间的数据库连接以避免因为没有释放数据库而引起的数据库遗漏.

连接池的创建分为以下几个步骤:1.配置context.xml文件  这个文件是服务器(指tomcat)的一个conf文件夹中,拷贝出来放入项目的lib文件夹中,具体配置如下:

[c-sharp] view plain copy

<Resource name="jdbc/book" auth="Container" type="javax.sql.DataSource"

maxActive="100" maxIdle="20" maxWait="100" username="sa" password="sa"

driverClassName="com.microsoft.sqlserver.jdbc.SQLServerDriver"

url="jdbc:sqlserver://localhost:1433dataBaseName=book"

/>在config.xml文件中加入Resource标签,然后对数据库信息进行配置,当然这个数据库指的也是sqlserver有疑问可以qq757966892联系

之后把数据库的驱动包,这里指的是sql2005的包放入服务器的lib中,这样以后如果在你自己的机子上都不用在重新导入这个包了.

然后就是从MyEclipse中取得这样的连接从而对数据库进行一些 *** 作具体代码如下:

[c-sharp] view plain copy

package web.login.dao

import java.sql.Connection

import java.sql.PreparedStatement

import java.sql.ResultSet

import javax.naming.Context

import javax.naming.InitialContext

import javax.sql.DataSource

public class BaseDao {

protected Connection conn

protected PreparedStatement ps

protected ResultSet rs

protected String sql

public Connection getConn(){

try {

Context context=new InitialContext()

DataSource ds=(DataSource)context.lookup("java:comp/env/jdbc/user")

return ds.getConnection()

} catch (Exception e) {

e.printStackTrace()

return null

}

}

public void closeAll(Connection conn,PreparedStatement ps,ResultSet rs){

try {

if(rs!=null){

rs.close()

rs=null

}

if(ps!=null){

ps.close()

ps=null

}

if(conn!=null){

conn.close()

conn=null

}

} catch (Exception e) {

e.printStackTrace()

}

}

}

之后便可以建立业务类从而对数据库进行 *** 作.


欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/sjk/6704963.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-03-27
下一篇 2023-03-27

发表评论

登录后才能评论

评论列表(0条)

保存