创建JDBC的基础类
import java.sql.Connection;
import java.sql.DriverManager;
/**
* 2012-8-9 tracy.liuy
*/
public class DbConnection {
public Connection conn = null;
public DbConnection(String driver, String url, String user, String password){
try {
// 注册驱动程序类
Class.forName(driver);
// 1、初始化连接对象
conn = DriverManager.getConnection(url, user, password);
// 2、设置连接对象的自动提交模式
conn.setAutoCommit(false);
} catch (Exception e) {
throw new RuntimeException("get connect failed", e);
}
}
}
连接Mysql数据库的示例
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Date;
import java.util.LinkedList;
import java.util.List;
import java.io.BufferedReader;
/**
* 2012-8-9 tracy.liuy
*/
public class TestMysql {
public static void main(String[] args) {
DbConnection dbC = new DbConnection("com.mysql.jdbc.Driver", "address",
"username", "password");
Statement stat = null;
//要执行的sql语句从文件中读出来
File f = new File("e:/mysql.update_customers.sql");
BufferedReader br = null;
Date date = null;
List<String> lines = new LinkedList<String>();
String line;
try {
stat = dbC.conn.createStatement();
br = new BufferedReader(new FileReader(f));
line = br.readLine();
while (line != null) {
lines.add(line);
line = br.readLine();
}
System.out.println("Start");
date = new Date();
for (String s : lines) {
stat.executeUpdate(s);
}
//connection设置为自动不提交,所以手动提交
dbC.conn.commit();
} catch (IOException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
dbC.conn.close();
br.close();
} catch (SQLException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
System.out.println("end. Duration is " + getDuration(date) + ", line is " + lines.size());
}
public static String getDuration(Date startTime) {
long duration = new Date().getTime() - startTime.getTime();
return duration / (1000 * 60) + "分" + (duration % (1000 * 60)) / 1000 + "秒";
}
}
连接Oracle的示例
import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Date;
import java.util.LinkedList;
import java.util.List;
/**
* 2012-8-9 tracy.liuy
*/
public class TestOracle {
public static void main(String[] args) {
DbConnection dbC = new DbConnection("oracle.jdbc.OracleDriver", "jdbc:oracle:thin:@ip:port:sid",
"username", "password");
Statement stat = null;
File f = new File("e:/oracle.update_customers.sql");
BufferedReader br = null;
Date date = null;
List<String> lines = new LinkedList<String>();
String line;
try {
stat = dbC.conn.createStatement();
br = new BufferedReader(new FileReader(f));
line = br.readLine();
while (line != null) {
lines.add(line);
line = br.readLine();
}
System.out.println("Start");
date = new Date();
for (String s : lines) {
stat.executeUpdate(s);
}
dbC.conn.commit();
} catch (IOException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
dbC.conn.close();
br.close();
} catch (SQLException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
System.out.println("end. Duration is " + getDuration(date) + ", line is " + lines.size());
}
public static String getDuration(Date startTime) {
long duration = new Date().getTime() - startTime.getTime();
return duration / (1000 * 60) + "分" + (duration % (1000 * 60)) / 1000 + "秒";
}
}
分享到:
相关推荐
sql2005-jdbc连接示例及jar包
Hive JDBC连接示例该项目展示了如何使用各种不同的方法连接到Hiveserver2。 所有类仅适用于Hiveserver2。 正在使用Cloudera JDBC驱动程序,可以从下载。 在撰写本文时,最新版本为v2.5.15 。要求: 您需要下载驱动...
包含了DB2通过JDBC连接数据库进行数据查询和SQL Server通过JDBC进行数据查询的示例以及相应的jar包文件。
jdbc连接oracle简单示例(环境为eclipse+oracle)
JAVA JDBC数据库连接字符串 jdbc连接字符串 内有多各数据库的示例! Oracle mysql sqlserver...
主要介绍了Java使用Jdbc连接Oracle执行简单查询操作,结合实例形式详细分析了java基于jdbc实现Oracle数据库的连接与查询相关操作技巧,需要的朋友可以参考下
JDBC对数据库进行操作的小例子,包括增、删、改、查。
这是JDBC连接SQL Server2008示例代码,其中有一份是在“SQL Server Authentication”模式下的,即需要账号密码,另一份为在“Windows Authentication”模式下的,不需要账号密码
SpringBoot项目通过采用JDBC驱动连接MySql数据库简单示例demo
一个JDBC连接MySQL数据库的小例子,供初学者参考!
oracle jdbc驱动 0分下载 内附连接示例 注意修改示例内数据库名,及用户和密码默认为 scott tiger
主要介绍了java使用jdbc连接数据库的工具类和使用jdbc连接mysql数据的示例,需要的朋友可以参考下
里面详细记录了JDBC连接数据库方法的文档,并附有示例
主要介绍了Java使用JDBC连接postgresql数据库,结合实例形式分析了jdbc连接postgresql数据库及数值插入、更新、查询等相关操作技巧,需要的朋友可以参考下
包含有SQL2000JDBC SQL2005JDBC ORACLEJDBC MYSQLJDBC 的jar包及连接示例
国外网站上讲解android上用jdbc 连接 mysql oracle sqlserver等数据库的示例; 英文阅读不行的不要下载.全是英文的
配套博客的资源,具体介绍见本人博客 Java工程通过JDBC连接数据库方法(SQL Server)
多种:jdbc连接池资源声明
收集 SQL DB2 MYSQL ORACLE ....等数据库连接的方式方法总汇,附带示例代码
jdbc连接MySQL进行增删改查等操作的源码示例。有创建实体类进行操作和不创建实体类进行操作的两种方法