【文件属性】：
文件名称：JAVA连接ORACLE数据库方法及测试
文件大小：32KB
文件格式：DOC
更新时间：2016-11-30 02:10:02
Oracle数据库
import java.sql.*;
public class Bc {
// 声明数据库地址及驱动
private Connection conn = null;
private String url = "jdbc:oracle:thin:@localhost:1521:ORCL";
private String driver = "oracle.jdbc.driver.OracleDriver";
private String user = "www";
private String password = "www";
// 主函数
public static void main(String[] args) {
Bc bc = new Bc();
String sql="select * from T_USERS";
String sql1 = "insert into T_USERS values ('rrr','ooo')";
String sql2 ="update T_USERS set USERSPASSWORD = '888888888884444' where USERSNAME= 'www'";
ResultSet rs= bc.select(sql);
bc.execute(sql1);
bc.execute(sql2);
try{
//显示查询出来的结果------------------
ResultSetMetaData rmeta = rs.getMetaData();
//获得数据字段个数
int numColumns = rmeta.getColumnCount();
while(rs.next())
{
for(int i = 0;i< numColumns;i++)
{
String sTemp = rs.getString(i+1);
System.out.print(sTemp+" ");
}
System.out.println("");
}
}
catch (Exception e) {
// TODO: handle exception
}
}
// 创建数据库连接方法
public Connection create() {
try {
/* 使用Class.forName()方法自动创建这个驱动程序的实例且自动调用DriverManager来注册它 */
Class.forName(driver);
/* 通过DriverManager的getConnection()方法获取数据库连接 */
conn = DriverManager.getConnection(url, user, password);
} catch (Exception ex) {
System.out.println("数据库连接出错");
}
return conn;
}
// 执行查询时用的方法
public ResultSet select(String sql) {
Connection c = create();//获取连接对象,可以不声明
ResultSet rs = null;
try {
Statement st = c.createStatement();// 获取Staetment对象
rs = st.executeQuery(sql);// 执行操作
} catch (Exception e) {
System.out.println("查询出错");
}
return rs;
}
// 更新方法
public void execute(String sql) {
Connection c = create();//获取连接对象,可以不声明
ResultSet rs = null;
try {
Statement st = c.createStatement();// 获取Staetment对象
st.executeUpdate(sql);
} catch (Exception e) {
System.out.println("更新出错");
}
}
}