operateoracle.java

java工厂模式实现

package org.database;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class OperateOracle implements OperateDataBase {

	public void insert() {
		// TODO Auto-generated method stub
		String url = "jdbc:oracle:thin@127.0.0.1:1520:ora9";
		System.setProperty("jdbc.drivers", "com.mysql.jdbc.Driver");
		String sql = "insert into customer (name， password) values (?,?)";
		try {
			Connection conn = DriverManager.getConnection(url, "root", "sa");
			if (!conn.isClosed())
				System.out.println("数据库连接成功");
			PreparedStatement pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, "name5");
			pstmt.setString(2, "password5");
			pstmt.executeUpdate();
			pstmt.setString(1, "name6");
			pstmt.setString(2, "password6");
			pstmt.executeUpdate();
			pstmt.close();
			conn.close();
		} catch (SQLException e) {
			e.getStackTrace();
		}

	}

	public void update() {
		// TODO Auto-generated method stub
		String url = "jdbc:oracle:thin@127.0.0.1:1520:ora9";
		System.setProperty("jdbc.drivers", "com.mysql.jdbc.Driver");
		String sql = ("UPDATE customer SET name='xiaowang' || where name='name5'");
		try {
			Connection conn = DriverManager.getConnection(url, "root", "sa");
			if (!conn.isClosed())
				System.out.println("数据库连接成功");
			Statement stmt = conn.createStatement();
			stmt.executeUpdate(sql);
			stmt.close();
			conn.close();
		} catch (SQLException e) {
			e.getStackTrace();
		}

	}

	public void delete() {
		// TODO Auto-generated method stub
		String url = "jdbc:oracle:thin@127.0.0.1:1520:ora9";
		System.setProperty("jdbc.drivers", "com.mysql.jdbc.Driver");
		String sql = "delect from customer where name='name2'";
		try {
			Connection conn = DriverManager.getConnection(url, "root", "sa");
			if (!conn.isClosed())
				System.out.println("数据库连接成功");
			Statement stmt = conn.createStatement();
			stmt.executeUpdate(sql);
			stmt.close();
			conn.close();
		} catch (SQLException e) {
			e.getStackTrace();
		}
	}

	public void query() {
		// TODO Auto-generated method stub
		String url = "jdbc:oracle:thin@127.0.0.1:1520:ora9";
		System.setProperty("jdbc.drivers", "com.mysql.jdbc.Driver");
		String sql = "Select * from customer";
		try {
			Connection conn = DriverManager.getConnection(url, "root", "sa");
			if (!conn.isClosed())
				System.out.println("数据库连接成功");
			Statement stmt = conn.createStatement();
			ResultSet rs = stmt.executeQuery(sql);
			while (rs.next()) {
				System.out.println("name:" + rs.getString(1) + "\tpassword:"
						+ rs.getString(2));
			}
			rs.close();
			stmt.close();
			conn.close();
		} catch (SQLException e) {
			e.getStackTrace();
		}
	}
}