Java数据库操作函数:如何连接、查询和更新MySQL和Oracle数据库?
Java是一种跨平台的编程语言,能够处理不同类型的数据和数据存储方式。在Java应用程序中,常使用关系型数据库来存储和管理数据。常见的关系型数据库有MySQL和Oracle。本文将介绍如何使用Java连接、查询和更新MySQL和Oracle数据库。
一、连接MySQL数据库
在Java中连接MySQL数据库有两种方式,一种是使用JDBC连接MySQL数据库,另一种是使用第三方框架连接MySQL数据库。
1、JDBC连接MySQL数据库
使用JDBC连接MySQL数据库,需要准备以下环境:
? Java Development Kit(JDK),版本需要是1.8或更高版本。
? MySQL Connector/J 驱动程序:下载地址为https://dev.mysql.com/downloads/connector/j/
步骤如下:
1)使用Eclipse等开发工具新建Java项目。
2)将下载好的mysql-connector-java.jar文件添加到项目lib目录下。
3)编写连接数据库的代码如下:
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class JdbcMysql {
public static void main(String[] args) {
// 定义数据库连接相关变量
String driver = "com.mysql.jdbc.Driver";
String url = "jdbc:mysql://localhost:3306/test";
String user = "root";
String password = "password";
Connection conn = null;
try {
// 加载JDBC驱动
Class.forName(driver);
// 连接数据库
conn = DriverManager.getConnection(url, user, password);
if(conn !=null) {
System.out.println("数据库连接成功!");
}
} catch (ClassNotFoundException e) {
System.out.println("JDBC驱动未找到!");
e.printStackTrace();
} catch (SQLException e) {
System.out.println("数据库连接失败!");
e.printStackTrace();
} finally {
try {
if(conn !=null) {
conn.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
2、使用第三方框架连接MySQL数据库
使用第三方框架连接MySQL数据库,常用的有Spring JDBC、MyBatis和Hibernate等。这里以Spring JDBC为例介绍如何连接MySQL数据库。
连接MySQL数据库需要准备以下环境:
? Spring Framework:下载地址为https://spring.io/
? MySQL Connector/J 驱动程序
步骤如下:
1)使用Eclipse等开发工具新建Java项目。
2)将Spring Framework和mysql-connector-java.jar文件添加到项目lib目录下。
3)在项目中新建一个Spring配置文件如下:
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd">
<bean id="dataSource"
class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://localhost:3306/test"/>
<property name="username" value="root"/>
<property name="password" value="password"/>
</bean>
</beans>
4)编写Java代码如下:
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DriverManagerDataSource;
public class SpringJdbcMysql {
public static void main(String[] args) {
DriverManagerDataSource dataSource = new DriverManagerDataSource();
dataSource.setDriverClassName("com.mysql.jdbc.Driver");
dataSource.setUrl("jdbc:mysql://localhost:3306/test");
dataSource.setUsername("root");
dataSource.setPassword("password");
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
String sql = "SELECT COUNT(1) FROM user";
int count = (int) jdbcTemplate.queryForObject(sql, Integer.class);
System.out.println("user表中有" + count + "条记录");
}
}
二、连接Oracle数据库
在Java中连接Oracle数据库可以使用JDBC连接Oracle数据库或使用第三方框架连接Oracle数据库。
1、JDBC连接Oracle数据库
使用JDBC连接Oracle数据库,需要准备以下环境:
? JDK
? Oracle JDBC driver:下载地址为https://www.oracle.com/database/technologies/jdbc-driver-ucp-downloads.html
步骤如下:
1)使用Eclipse等开发工具新建Java项目。
2)将下载好的ojdbc7.jar文件添加到项目lib目录下。
3)编写连接数据库的代码如下:
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class JdbcOracle {
public static void main(String[] args) {
// 定义数据库连接相关变量
String driver = "oracle.jdbc.driver.OracleDriver";
String url = "jdbc:oracle:thin:@localhost:1521:orcl";
String user = "username";
String password = "password";
Connection conn = null;
try {
// 加载JDBC驱动
Class.forName(driver);
// 连接数据库
conn = DriverManager.getConnection(url, user, password);
if(conn !=null) {
System.out.println("数据库连接成功!");
}
} catch (ClassNotFoundException e) {
System.out.println("JDBC驱动未找到!");
e.printStackTrace();
} catch (SQLException e) {
System.out.println("数据库连接失败!");
e.printStackTrace();
} finally {
try {
if(conn !=null) {
conn.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
2、使用第三方框架连接Oracle数据库
使用第三方框架连接Oracle数据库,常用的有Spring JDBC、MyBatis和Hibernate等。这里以Spring JDBC为例介绍如何连接Oracle数据库。
连接Oracle数据库需要准备以下环境:
? Spring Framework
? Oracle JDBC driver
步骤如下:
1)使用Eclipse等开发工具新建Java项目。
2)将Spring Framework和ojdbc7.jar文件添加到项目lib目录下。
3)在项目中新建一个Spring配置文件如下:
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd">
<bean id="dataSource"
class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/>
<property name="url" value="jdbc:oracle:thin:@localhost:1521:orcl"/>
<property name="username" value="username"/>
<property name="password" value="password"/>
</bean>
</beans>
4)编写Java代码如下:
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DriverManagerDataSource;
public class SpringJdbcOracle {
public static void main(String[] args) {
DriverManagerDataSource dataSource = new DriverManagerDataSource();
dataSource.setDriverClassName("oracle.jdbc.driver.OracleDriver");
dataSource.setUrl("jdbc:oracle:thin:@localhost:1521:orcl");
dataSource.setUsername("username");
dataSource.setPassword("password");
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
String sql = "SELECT COUNT(1) FROM user";
int count = (int) jdbcTemplate.queryForObject(sql, Integer.class);
System.out.println("user表中有" + count + "条记录");
}
}
三、查询和更新数据库
查询和更新数据库是Java与数据库的交互中最常用的操作。下面分别介绍如何查询和更新MySQL和Oracle数据库。
1、查询MySQL数据库
使用Java查询MySQL数据库,可以使用JDBC或使用第三方框架。
1)使用JDBC查询MySQL数据库
使用JDBC查询MySQL数据库的代码如下:
`
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class JdbcMysql {
public static void main(String[] args) {
// 定义数据库连接相关变量
String driver = "com.mysql.jdbc.Driver";
String url = "jdbc:mysql://localhost:3306/test";
String user = "root";
String password = "password";
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
try {
// 加载JDBC驱动
Class.forName(driver);
// 连接数据库
conn = DriverManager.getConnection(url, user, password);
stmt = conn.createStatement();
rs = stmt.executeQuery("SELECT * FROM user");
while (rs.next()) {
System.out.println(rs.getInt(
