java 实现 jdbc连接oracle 数据库的java代码怎么写

package comjdbctest;

import javasqlConnection;

import javasqlDriverManager;

import javasqlResultSet;

import javasqlStatement;

public class JDBCTest {

public static void main(String[] args) throws Exception {

//1加载驱动

//ClassforName("commicrosoftsqlserverjdbcSQLServerDriver");

//ClassforName("commysqljdbcDriver");

ClassforName("oraclejdbcdriverOracleDriver");

//2创建数据库连接对象

//Connection conn = DriverManagergetConnection("jdbc:sqlserver://localhost:1433;databaseName=db","sa","sqlpass");

//Connection conn = DriverManagergetConnection("jdbc:mysql://localhost:3306/dbuseUnicode=true&characterEncoding=UTF-8","root","123456");

Connection conn = DriverManagergetConnection("jdbc:oracle:thin:@localhost:1521:orcl","scott","Oracle123");

//3创建数据库命令执行对象

Statement stmt = conncreateStatement();

// PreparedStatement ps = connprepareStatement("select from t_user");

//4执行数据库命令

ResultSet rs = stmtexecuteQuery("select from t_user");

// ResultSet rs = psexecuteQuery();

//5处理执行结果

while (rsnext()) {

int id = rsgetInt("id");

String username = rsgetString("username");

String password = rsgetString("password");

Systemoutprintln(id + "\t" + username + "\t" + password);

}

//6释放数据库资源

if (rs != null) {

rsclose();

}

// if (ps != null) {

// psclose();

// }

if (stmt != null) {

stmtclose();

}

if (conn != null) {

connclose();

}

}

}

这是以前写的3中数据库的链接已经测试过了。

你没要读取的，我没写。用的MySQL数据库

DROP TABLE IF EXISTS `t_song_file`;

CREATE TABLE `t_song_file` (

`id` int(11) NOT NULL AUTO_INCREMENT,

`file_name` varchar(50) DEFAULT NULL,

`file` blob,

PRIMARY KEY (`id`)

) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8

package comsongtest;

import javaioFile;

import javaioFileInputStream;

import javaioInputStream;

import javasqlConnection;

import javasqlPreparedStatement;

import comsongdaoDBUtil;

public class InputStreamInDB {

public static void main(String[] args) throws Exception {

Connection conn=DBUtilgetConnection();

String sql="insert into t_song_file(file_name,file) values(,)";

PreparedStatement ps=connprepareStatement(sql);

pssetString(1, "hellozip");

pssetBlob(2, getFileInputStream("C:/Users/songjunliang/Desktop/hellozip"));

int tag=psexecuteUpdate();

if(1==tag)

{

Systemoutprintln("success");

}

psclose();

connclose();

}

public static InputStream getFileInputStream(String filePath) throws Exception

{

File file=new File(filePath);

InputStream is=new FileInputStream(file);

return is;

}

}

public class JDBConnect {

//private static final String DRIVER="commysqljdbcDriver";

private static final String DRIVER="commicrosoftsqlserverjdbcSQLServerDriver";

//private static final String URI="jdbc:mysql://localhost:3306/数据库名称";

private static final String URI="jdbc:sqlserver://127001:1433; DatabaseName=数据库名称";

private static final String USER="sa";

private static final String pwd="sasa";

public static Connection getConnection(){

Connection con=null;

try{

ClassforName(DRIVER);

}catch(ClassNotFoundException e){

Systemoutprintln("加载驱动错误信息：" + egetMessage());

}

try{

con=DriverManagergetConnection(URI,USER,pwd);

}catch(SQLException e){

Systemoutprintln("数据库连接错误信息：" + egetMessage());

eprintStackTrace();

}

return con;

}

}

import javasqlConnection;

import javasqlDriverManager;

import javasqlResultSet;

import javasqlSQLException;

import javasqlStatement;

public class Test {

public static void main(String[] args){

try {

String[] ss=getSameJH();

} catch (Exception e) {

eprintStackTrace();

}

}

public static String driver = "oraclejdbcdriverOracleDriver";

public static String url = "jdbc:oracle:thin:@1921671102:1521:orcl";

public static String dbUser = "tqdb";

public static String dbPwd = "tqdb";

public static String[] getSameJH() throws Exception{

String[] ss=new String[100];

Connection conn=getConnection();

String sql="select a．jh　from　table1　a join table2　b on　a．jh＝b．jh";

Statement st=conncreateStatement();

ResultSet rs=stexecuteQuery(sql);

int i=0;

while(rsnext()){

String s=rsgetString("jh");

ss[i++]=s;

}

return ss;

}

// 获取连接

public static Connection getConnection() throws Exception {

Connection conn = null;

try {

ClassforName(driver);

conn = DriverManagergetConnection(url, dbUser, dbPwd);

} catch (Exception e) {

eprintStackTrace();

throw e;

}

return conn;

}

public static void getClose(Connection conn) throws SQLException {

if (conn != null) {

try {

connclose();

} catch (SQLException e) {

eprintStackTrace();

throw e;

}

}

}

}

//根据excel文件，生成输入流

FileInputStream fis = new FileInputStream(new File("D:\\aaxlsx"));

//用输入流生成poi 对象,以读取excel内容

//excel2007以上用XSSFWorkbook，2003用HSSFWorkbook

Workbook workbook = new XSSFWorkbook(fis);

Sheet sheet = workbookgetSheetAt(0);//取第一个sheet

String str1 = sheetgetRow(0)getCell(0)getStringCellValue();//取第一行第一列字符值

//getDateCellValue();日期类型 getNumericCellValue()数字类型;getHyperlink()超链接 等等()

//接下来 选择性插入数据库吧，明白

连接数据库

import javasqlConnection;

import javasqlDriverManager;

import javasqlSQLException;

import javasqlStatement;

public class TestDB {

public static void main(String[] args) {

try {

// 1注册驱动

ClassforName("commicrosoftsqlserverjdbcSQLServerDriver");

Systemoutprintln("注册驱动成功");

String url = ""jdbc:microsoftsqlserver://127001:1433;DatabaseName="; //数据库IP,端口,数据库名

String username = "";

String password = "";

// 加载驱动并获取数据库连接对象

Connection connection = DriverManagergetConnection(url, username,

password);

Systemoutprintln("连接数据库成功！");

// 创建Statement对象

Statement stmt = connectioncreateStatement();

// SQL语句

String sql = "insert into student(id,name,age,email,address) values(1,'tom',23,'dfg@163com','England') ";

int rows = stmtexecuteUpdate(sql);

if (rows > 0) {

Systemoutprintln("插入成功!");

}

// 释放资源

stmtclose();

connectionclose();

} catch (SQLException e) {

eprintStackTrace();

}

catch (ClassNotFoundException e) {

eprintStackTrace();

}

}

}

预编译的数据库处理

public class ConnectionManager{

public static final String DRIVER_CLASS ="";

public static final String URL = "";

public static final String USERNAME = "";

public static final String PASSWORD = "";

//获取连接对象

public static Connection getConnection(){

Connection conn = null;

ClassforName(DRIVER_CLASS);

conn = DriverManagergetConnection(URL,USERNAME,PASSWORD);

return conn;

}

public static void closeAll(ResultSet rs,Statement stmt,Connection conn){

try{

if(rs!=null){

rsclose();

rs = null;

}

if(stmt!=null){

stmtclose();

stmt = null;

}

if(conn!=null){

connclose();

conn=null;

}

}

}

}

public class DBOperator{

public int executeUpdate(String sql,Object[] params){

int rows = 0;

Connection connn = ConnectionManagergetConnection();

PreparedStatement pstmt = connprepareStatement(sql);

if(params!=null){

for(int i=0;i<paramslength;i++){

pstmtsetObject(i+1,params[i]);//下标从1开始

}

}

rows = pstmtexecuteUpdate();

ConnectionManagercloseAll(null,pstmt,conn);

return rows;

}

public ResultSet executeQuery(String sql,Object[] params){

Connetion conn = ConnectionManagergetConnection();

if(params!=null){

for(int i= 0;i<paramslength;i++){

pstmtsetObject(i+1,params(i));

}

}

rs=pstmtexecuteQuery();

ConnectionManagercloseAll(rs,pstmt,conn);

return rs;

}

}

/

statement连接数据库

/

public class TestOperatorGrade{

private static void updateGrade(int id,String name,String description){

ClassforName();//注册驱动

Connection conn = DirverManagergetConnection("","","");

Statement stmt = conncreateStament();

String sql = "UPDATE grades set name = '"+name+"',description='"+description+"'WHere id="+id;

int rows = stmtexecuteUpdate(sql);

}

}

这是java 程序的代码

敲个例子给你参考一下

import javaawtBorderLayout;

import javaawteventActionEvent;

import javaawteventActionListener;

import javasqlConnection;

import javasqlDriverManager;

import javasqlPreparedStatement;

import javasqlResultSet;

import javasqlSQLException;

import javaxswingJButton;

import javaxswingJFrame;

import javaxswingJTextArea;

import javaxswingJTextField;

public class JDBCTest extends JFrame implements ActionListener {

private Connection conn;

private JTextField textField;

private JButton button;

private JTextArea textArea;

private PreparedStatement ps;

private ResultSet rs;

public JDBCTest() {

super("查询");

textField = new JTextField("输入查询的姓名");

textArea = new JTextArea();

button = new JButton("查询");

buttonaddActionListener(this);

thisadd(textField, BorderLayoutNORTH);

thisadd(textArea);

thisadd(button, BorderLayoutSOUTH);

thissetSize(350, 200);

thissetResizable(false);

thissetLocationRelativeTo(null);

thissetDefaultCloseOperation(3);

thissetVisible(true);

}

public Connection getConnection() {

try {

ClassforName("oraclejdbcdriverOracleDriver");

conn = DriverManager

getConnection("jdbc:oracle:thin:@1271:1521:orcl", "scott", "tiger");

return conn;

} catch (ClassNotFoundException e) {

eprintStackTrace();

} catch (SQLException e) {

eprintStackTrace();

}

return null;

}

public void actionPerformed(ActionEvent e) {

textAreasetText(null);

try {

ps = getConnection()

prepareStatement("select from mytable where 姓名 = ");

pssetString(1, textFieldgetText()trim());

rs = psexecuteQuery();

if (rsnext()) {

textAreaappend("姓名：" + rsgetObject(1) + "\t年龄：" + rs

getObject(2) + "\t性别：" + rsgetObject(3));

}

} catch (SQLException e1) {

e1printStackTrace();

}

}

public static void main(String[] args) {

new JDBCTest();

}

}

效果图：

以上就是关于java 实现 jdbc连接oracle 数据库的java代码怎么写全部的内容，包括:java 实现 jdbc连接oracle 数据库的java代码怎么写、怎样把一个zip文件插入数据库，求完整的Java代码实现，急急急、求java链接sqlserver数据库的代码，以及配置等相关内容解答，如果想了解更多相关内容，可以关注我们，你们的支持是我们更新的动力！