数据库连接方式
- ODBC
- JDBC
常见错误
1.Exception in thread “main” java.lang.ClassNotFoundException: ora1cle.jdbc.driver.OracleDriver
-
驱动路径名称错误 oracle.jdbc.driver.OracleDriver
-
驱动包没有添加到类路径中
2.Exception in thread “main” java.sql.SQLException: No suitable driver found for jdbc:orcale:thin:@localhost:1521:orcl
- url写错了
3.ORA-12505, TNS:listener does not currently know of SID given in connect descriptor
- url中数据库名称错误
4.Exception in thread “main” java.sql.SQLException: The Network Adapter could not establish the connection
-
监听未开启
-
监听的端口号错误
5.Exception in thread “main” java.sql.SQLException: ORA-01017: invalid username/password; logon denied
- 登录用户名或密码错误
6.Exception in thread “main” java.sql.SQLException: 列名无效
-
该表中没有该列名的存在 update insert delete
-
查询语句中没有查询出该列
步骤
1.从Oracle文件下找到jdbc驱动包 ojdbc14.jar
2.项目创建及jar文件导入
1.创建JavaProject
2.项目下创建一个文件夹lib
项目上右键
new
Folder
3.将ojdbc14.jar文件复制到lib目录下
4.选中ojdbc14.jar右击—build path—add buildpath
5.注意：打开数据库监听及服务
3.数据库连接步骤eclipse中
1.导包
import java.sql.*;
2.注册驱动
Class.forName("oracle.jdbc.driver.OracleDriver");
3.获取连接对象
Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:orcl","scott","a");
Connection 与特定数据库的连接（会话）在连接上下文中执行SQL语句并返回结果
//第一个参数：jdbc连接数据的url地址 jdbc:oracle:thin:@数据库服务IP:数据库端口号:数据库实例名
//第二个参数：登录数据库服务器的用户名
//第三个参数：登录数据库服务器的密码
Java与数据库可以通信 创建session窗口
4.测试是否连接成功
System.out.println(conn.getClass().getName());
连接成功：oracle.jdbc.driver.T4CConnection
5.编写sql语句
需传入的参数用占位符？代替
String sql ="select usid,uname,upwd,uimage,utype,ustate from tb_user where uname=? and upwd=?"
6.通过连接对象加载sql语句获取预编译对象
SQL语句被预编译并存储在PrepareStatement对象中
PrepareStatement pstmt = conn.prepareStatement(sql)
7.给？参数设值
pstmt.setObject(1, uname);//1表示第几个问好
pstmt.setObject(2, pwd);
8.执行查询操作
在此 PreparedStatement 对象中执行 SQL 查询，并返回该查询生成的 ResultSet 对象
即在数据库中执行sql语句
ResultSet rs = pstmt.executeQuery()
rs.next()
next方法将光标移动到下一行 在ResultSet对象没有下一行时返回false
rs.getObject("empno")
获取empno字段的值
9.关闭所有资源
10以上保存在Map中（多Map又可以添加在list中）
添加图片—更新操作
//图片的添加 以字节的方式插入
File f = new File("E:\\Orecle_WordSpace\\1.jpg");
InputStream in = new FileInputStream(f);
byte []bt=new byte[(int)f.length()];
in.read(bt);
pstmt.setObject(3, bt);
int result=pstmt.executeUpdate();
- 在数据库查询该表时，该条数据已被添加!
配置文件db.propreties
-
driver_name
注册驱动
-
url
-
user
-
password
MyProperties
public class MyProperties extends Properties {
public static MyProperties instance = new MyProperties();
private MyProperties(){
try {
this.load(this.getClass().getClassLoader().getResourceAsStream("db.properties"));//类路径 src
//若配置文件放在com.yc.cammons caom/yc/commons/db.properties
} catch (IOException e) {
e.printStackTrace();
}
}
public static MyProperties getInstince(){
return instance;
}
}
帮助文档-DBHelper
1.全局变量
private Connection conn;
private PreparedStatement pstmt;
private ResultSet rs;
2.驱动加载static{}
static{
try {
Class.forName(MyProperties.getInstince().getProperty("driver_name"));
} catch (ClassNotFoundException e) {
System.out.println("驱动注册失败"+e.getMessage());//项目上线需删除此行
e.printStackTrace();
}
}
3.获取连接对象Connection getConn()
public Connection getConn(){
try {
Properties p = MyProperties.getInstince();
conn = DriverManager.getConnection(p.getProperty("url"),p);
} catch (SQLException e) {
System.out.println("获取连接对象失败："+e.getMessage());
e.printStackTrace();
}
return conn;
}
4.设置参数? void setParams(PreparedStatement pstmt,Object…params)
public void setParams(PreparedStatement pstmt,Object...params) throws Exception{//参数数量无法确定 用不定长度的数组
if(params==null||params.length<=0){return ;}
//循环数组
for(int i=0;i<params.length;i++){
pstmt.setObject(i+1, params[i]);
}
}
5.根据结果集获取所有列名 List getColumnNames(ResultSet rs)
public List<String> getColumnNames(ResultSet rs) throws SQLException{
List<String> colunmNames = new ArrayList<String>();
//通过结果集对象获取结果集所有的列及属性
ResultSetMetaData data = rs.getMetaData();// 获取此 ResultSet 对象的列的编号、类型和属性
int count = data.getColumnCount();//根据sql语句查看列的条数
//列的编号从1开始
for(int i=1;i<=count;i++){
colunmNames.add(data.getColumnName(i));
}
return colunmNames;
}
6.更新操作
1.单条sql语句更新
int update(String sql,Object…params)
public int update(String sql,Object...params) throws Exception{
int result=0;//记录更新条数
try {
conn=getConn();//获取连接对象
pstmt=conn.prepareStatement(sql);//获取预编译对象
setParams(pstmt, params);//设置参数
result=pstmt.executeUpdate();//更新
} catch (SQLException e) {
e.printStackTrace();
System.out.println("单条更新异常："+e.getMessage());
}finally {
closeAll(conn, pstmt, null);
}
return result;
}
2.多条sql语句更新——用事务来处理
int update(List<String> sqls,List<List<Object>> params)
public int update(List<String> sqls,List<List<Object>> params) throws Exception{
int result = 0;
try {
conn=getConn();
conn.setAutoCommit(false);//将事务设为手动处理 Connection对象处于自动提交状态
for(int i=0;i<sqls.size();i++){//循环所有的sql语句
String sql = sqls.get(i);//获取单条sql语句
List<Object> param = params.get(i);//获取与sql语句对应位置的参数设置List
pstmt=conn.prepareStatement(sql);
//设置参数
setParams(pstmt, param.toArray());//将集合转为对象数组
result=pstmt.executeUpdate();
if(result<=0){
//更新受影响的函数认为更新失败，撤销前面所有的操作
conn.rollback();
return result;
}
}
conn.commit();//执行成功——手动提交事务
} catch (SQLException e) {
//事务回滚
conn.rollback();
result=0;
e.printStackTrace();
System.out.println("多条更新异常："+e.getMessage());
}finally {
//事务还原
conn.setAutoCommit(true);
closeAll(conn, pstmt, null);
}
return result;
}
7.查询操作
1.单个聚合函数查询
double getPloymer(String sql,Object…params)
select count(*) from 表名
public double getPloymer(String sql,Object...params) throws Exception{
double result=0;
try {
conn=getConn();
pstmt=conn.prepareStatement(sql);
setParams(pstmt, params);
rs=pstmt.executeQuery();
if(rs.next()){
result=rs.getDouble(1);//double 的形式获取此 ResultSet 对象的当前行中指定列的值 列1
}
} catch (SQLException e) {
e.printStackTrace();
throw new Exception("聚合函数查询失败："+e.getMessage());
}finally{
closeAll(conn, pstmt, rs);
}
return result;
}
2.返回一条查询结果(记录)
Map<String,Object> findSingle(String sql,Object…params)
public Map<String,Object> findSingle(String sql,Object...params) throws Exception{
Map<String,Object> map=null;
try {
conn=getConn();
pstmt=conn.prepareStatement(sql);
setParams(pstmt, params);
rs = pstmt.executeQuery();//返回查询出来的结果集
List<String> columnNames=getColumnNames(rs);//获取所有的列名
if(rs.next()){
map = new HashMap<String,Object>();
for(String name:columnNames){
Object obj = rs.getObject(name);//根据列名获取值
if(obj==null)continue;
String typeName = obj.getClass().getName();//获取当前值的数据类型
if("oracle.sql.BLOB".equals(typeName)){//照片处理
Blob blob = (BLOB)obj;
InputStream in = blob.getBinaryStream();
byte []bt=new byte[(int)blob.length()];
in.read(bt);//转换成二进制字节存入
map.put(name, bt);
}else if("oracle.sql.CLOB".equals(typeName)){
//文档
}else{
map.put(name, rs.getObject(name));
}
}
}
} catch (SQLException e) {
e.printStackTrace();
System.out.println("单条查询异常："+e.getMessage());
}finally {
closeAll(conn, pstmt, rs);
}
return map;
}
3.返回多条查询结果(记录)
List<Map<String,Object>> findMutipl(String sql,Object…params)
public List<Map<String,Object>> findMutipl(String sql,Object...params)throws Exception{
Map<String,Object> map=null;
List<Map<String,Object>> list=new ArrayList<Map<String,Object>>();
try {
conn=getConn();
pstmt=conn.prepareStatement(sql);
setParams(pstmt, params);
rs = pstmt.executeQuery();
List<String> columnNames=getColumnNames(rs);
while(rs.next()){
map = new HashMap<String,Object>();
for(String name:columnNames){
Object obj = rs.getObject(name);//根据名称获取值
if(obj==null)continue;
String typeName = obj.getClass().getName();//获取当前值的数据类型
if("oracle.sql.BLOB".equals(typeName)){//照片处理
Blob blob = (BLOB)obj;
InputStream in = blob.getBinaryStream();
byte []bt=new byte[(int)blob.length()];
in.read(bt);//转换成二进制字节存入
map.put(name, bt);
}else if("oracle.sql.CLOB".equals(typeName)){
//文档
}else{
map.put(name, rs.getObject(name));
}
}
list.add(map);
}
} catch (SQLException e) {
e.printStackTrace();
System.out.println("单条查询异常："+e.getMessage());
}finally {
closeAll(conn, pstmt, rs);
}
return list;
}
8.关闭所有资源
1.void closeAll(Connection conn,PreparedStatement pstmt,ResultSet rs)
public void closeAll(Connection conn,PreparedStatement pstmt,ResultSet rs){
if(conn!=null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
.......
}