您的位置:首页 > 数据库

JDBC快速入门教程,连接数据库不用愁。

2016-06-01 17:21 429 查看


本资料来自北京尚学堂科技有限公司。


DBC是什么?

JDBC API是一个Java API,可以访问任何类型表列数据,特别是存储在关系数据库中的数据。JDBC代表Java数据库连接。

JDBC库中所包含的API任务通常与数据库使用:

连接到数据库

创建SQL或MySQL语句

在数据库中执行SQL或MySQL查询

查看和修改记录


先决条件:

学习JDBC,需要在以下两个主题有一定的了解:

JAVA核心编程

SQL或MySQL数据库


JDBC - 环境设置:

请确认您已完成以下设置:

核心JAVA安装

SQL 或 MySQL数据库安装

除上述者外,需要建立一个数据库,为本程测试项目使用。假设这是EMP,在同一个数据库上创建表Employees。


创建JDBC应用程序:

参与建立一个JDBC应用程序,本教程中按六个步骤进行:


导入包:

这需要你有软件包包含了数据库编程所需的JDBC类。大多数情况下,使用import java.sql.* 就足够了,如下所示:

//STEP 1. Import required packages
import java.sql.*;


注册JDBC驱动程序:

这需要初始化驱动程序,这样就可以打开与数据库的通信信道。以下是代码片段实现这一目标:
//STEP 2: Register JDBC driver
Class.forName("com.mysql.jdbc.Driver");


打开一个连接:

这需要使用DriverManager.getConnection()方法来创建一个Connection对象,它代表一个物理连接的数据库,如下所示:
//STEP 3: Open a connection
//  Database credentials
static final String USER = "username";
static final String PASS = "password";
System.out.println("Connecting to database...");
conn = DriverManager.getConnection(DB_URL,USER,PASS);


执行一个查询:

这需要使用一个对象类型Statement或PreparedStatement构建,并提交一个SQL语句到数据库。如下:
//STEP 4: Execute a query
System.out.println("Creating statement...");
stmt = conn.createStatement();
String sql;
sql = "SELECT id, first, last, age FROM Employees";
ResultSet rs = stmt.executeQuery(sql);


如果有一个SQL UPDATE,INSERT或DELETE语句,那么需要下面的代码片段:
//STEP 4: Execute a query
System.out.println("Creating statement...");
stmt = conn.createStatement();
String sql;
sql = "DELETE FROM Employees";
ResultSet rs = stmt.executeUpdate(sql);


从结果集中提取数据:

这一步是必需的情况下,从数据库中获取数据。可以使用适当的ResultSet.getXXX()方法来检索的数据结果如下:
//STEP 5: Extract data from result set
while(rs.next()){
//Retrieve by column name
int id  = rs.getInt("id");
int age = rs.getInt("age");
String first = rs.getString("first");
String last = rs.getString("last");

//Display values
System.out.print("ID: " + id);
System.out.print(", Age: " + age);
System.out.print(", First: " + first);
System.out.println(", Last: " + last);
}


清理环境:

应该明确地关闭所有的数据库资源,对依赖于JVM的垃圾收集如下:
//STEP 6: Clean-up environment
rs.close();
stmt.close();
conn.close();


第一个JDBC 程序:

基于上面的步骤,我们可以有以下综合示例代码,我们可以用它作为模板而写JDBC代码:

此示例代码已被写入基于对环境和数据库环境一章中设置完成。
//STEP 1. Import required packages
import java.sql.*;
public class FirstExample {
// JDBC driver name and database URL
static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
static final String DB_URL = "jdbc:mysql://localhost/EMP";

// Database credentials
static final String USER = "username";
static final String PASS = "password";

public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
try{
//STEP 2: Register JDBC driver Class.forName("com.mysql.jdbc.Driver");

//STEP 3: Open a connection
System.out.println("Connecting to database...");
conn = DriverManager.getConnection(DB_URL,USER,PASS);

//STEP 4: Execute a query System.out.println("Creating statement..."); stmt = conn.createStatement(); String sql; sql = "SELECT id, first, last, age FROM Employees"; ResultSet rs = stmt.executeQuery(sql);
//STEP 5: Extract data from result set while(rs.next()){ //Retrieve by column name int id = rs.getInt("id"); int age = rs.getInt("age"); String first = rs.getString("first"); String last = rs.getString("last"); //Display values System.out.print("ID: " + id); System.out.print(", Age: " + age); System.out.print(", First: " + first); System.out.println(", Last: " + last); }//STEP 6: Clean-up environment rs.close(); stmt.close(); conn.close();}catch(SQLE
18f67
xception se){
//Handle errors for JDBC
se.printStackTrace();
}catch(Exception e){
//Handle errors for Class.forName
e.printStackTrace();
}finally{
//finally block used to close resources
try{
if(stmt!=null)
stmt.close();
}catch(SQLException se2){
}// nothing we can do
try{
if(conn!=null)
conn.close();
}catch(SQLException se){
se.printStackTrace();
}//end finally try
}//end try
System.out.println("Goodbye!");
}//end main
}//end FirstExample - by www.yiibai.com


现在让我们来编译上面的例子如下:
C:\>javac FirstExample.java
C:\>


当你运行FirstExample的,它会产生以下结果:
C:\>java FirstExample
Connecting to database...
Creating statement...
ID: 100, Age: 18, First: Zara, Last: Ali
ID: 101, Age: 25, First: Mahnaz, Last: Fatma
ID: 102, Age: 30, First: Zaid, Last: Khan
ID: 103, Age: 28, First: Sumit, Last: Mittal
C:\>


SQLException方法:

一个SQLException既可以发生在驱动程序和数据库。当这样的异常时,SQLException类型的对象将被传递到catch子句。

通过SQLException对象有以下几种方法可用于获取更多的关于异常的信息:
方法描述
getErrorCode()获取与异常关联的错误号。
getMessage()获取的JDBC驱动程序的错误处理错误消息的驱动程序,或获取Oracle错误号和消息的数据库错误。
getSQLState()获取XOPEN SQLSTATE字符串。对于JDBC驱动程序错误,没有有用的信息,从该方法返回。对于一个数据库错误,五位的XOPEN SQLSTATE代码返回。这种方法可以返回null。
getNextException()获取异常链中的下一个Exception对象。
printStackTrace()打印当前的异常,或可抛出,并回溯到标准错误流。
printStackTrace(PrintStream s)打印此抛出对象及其回溯到指定的打印流。
printStackTrace(PrintWriter w)打印此抛出对象及其回溯您指定打印作家。
通过利用从Exception对象提供的信息,可以捕获一个异常,并适当地继续运行程序。这是一个try块中的一般形式:
try {
// Your risky code goes between these curly braces!!!
}
catch(Exception ex) {
// Your exception handling code goes between these
// curly braces, similar to the exception clause
// in a PL/SQL block.
}
finally {
// Your must-always-be-executed code goes between these
// curly braces. Like closing database connection.
}


JDBC - 数据类型:

下表总结了默认的JDBC数据类型的Java数据类型转换,当调用PreparedStatement或CallableStatement对象的setXXX()方法,或ResultSet.updateXXX()方法。
SQLJDBC/JavasetXXXupdateXXX
VARCHARjava.lang.StringsetStringupdateString
CHARjava.lang.StringsetStringupdateString
LONGVARCHARjava.lang.StringsetStringupdateString
BITbooleansetBooleanupdateBoolean
NUMERICjava.math.BigDecimalsetBigDecimalupdateBigDecimal
TINYINTbytesetByteupdateByte
SMALLINTshortsetShortupdateShort
INTEGERintsetIntupdateInt
BIGINTlongsetLongupdateLong
REALfloatsetFloatupdateFloat
FLOATfloatsetFloatupdateFloat
DOUBLEdoublesetDoubleupdateDouble
VARBINARYbyte[ ]setBytesupdateBytes
BINARYbyte[ ]setBytesupdateBytes
DATEjava.sql.DatesetDateupdateDate
TIMEjava.sql.TimesetTimeupdateTime
TIMESTAMPjava.sql.TimestampsetTimestampupdateTimestamp
CLOBjava.sql.ClobsetClobupdateClob
BLOBjava.sql.BlobsetBlobupdateBlob
ARRAYjava.sql.ArraysetARRAYupdateARRAY
REFjava.sql.RefSetRefupdateRef
STRUCTjava.sql.StructSetStructupdateStruct
JDBC3.0的增强支持BLOB,CLOB,ARRAY,REF数据类型。的ResultSet对象UPDATEBLOB(),updateCLOB(),updateArray()和updateRef()方法,使您可以在服务器上直接操作相应的数据。

setXXX()和updateXXX()方法,可以转换成特定的Java类型到特定的JDBC数据类型。setObject()和updateObject()方法,几乎所有的Java类型映射到JDBC数据类型。

ResultSet对象提供相应的getXXX()方法为每个数据类型来检索列值。每一种方法,可以使用与列名或由它的序号位置。
SQLJDBC/JavasetXXXgetXXX
VARCHARjava.lang.StringsetStringgetString
CHARjava.lang.StringsetStringgetString
LONGVARCHARjava.lang.StringsetStringgetString
BITbooleansetBooleangetBoolean
NUMERICjava.math.BigDecimalsetBigDecimalgetBigDecimal
TINYINTbytesetBytegetByte
SMALLINTshortsetShortgetShort
INTEGERintsetIntgetInt
BIGINTlongsetLonggetLong
REALfloatsetFloatgetFloat
FLOATfloatsetFloatgetFloat
DOUBLEdoublesetDoublegetDouble
VARBINARYbyte[ ]setBytesgetBytes
BINARYbyte[ ]setBytesgetBytes
DATEjava.sql.DatesetDategetDate
TIMEjava.sql.TimesetTimegetTime
TIMESTAMPjava.sql.TimestampsetTimestampgetTimestamp
CLOBjava.sql.ClobsetClobgetClob
BLOBjava.sql.BlobsetBlobgetBlob
ARRAYjava.sql.ArraysetARRAYgetARRAY
REFjava.sql.RefSetRefgetRef
STRUCTjava.sql.StructSetStructgetStruct


JDBC - 批量处理:

批处理允许一个批处理组相关的SQL语句,并将其提交的一个调用到数据库。

当几个SQL语句一次发送到数据库中,可以减少通信开销,从而提高性能。

JDBC驱动程序不支持此功能。您应该使用DatabaseMetaData.supportsBatchUpdates()方法来确定目标数据库支持批量更新处理。如果你的JDBC驱动程序支持此功能,则该方法返回true。

addBatch()方法的声明,PreparedStatement和CallableStatementis用于添加单个语句的批处理。 executeBatch()将开始执行的所有语句组合到一起。

executeBatch()将返回一个整数数组,每个数组元素的表示为相应的更新语句的更新计数。

可以添加语句进行批处理,可以clearBatch()方法删除它们。此方法将删除addBatch()方法添加的所有语句。但是,你不能有选择性地选择语句来删除。


JDBC - 数据流:

PreparedStatement对象有能力使用提供参数数据的输入和输出流。这使您可以将整个文件到数据库中,可容纳较大的值,如CLOB和BLOB数据类型的列。

有下列方法可用于流数据:

setAsciiStream(): 此方法用于提供大的ASCII值。

setCharacterStream(): 此方法用于提供大的UNICODE值。

setBinaryStream(): 使用此方法,以提供大的二进制值。

setXXXStream()方法需要一个额外的参数,文件大小,除了参数占位符。此参数通知应发送多少数据的数据库,使用流的驱动程序。
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  java jdbc