operatemysql.java

java工厂模式实现

package org.database;

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

public class OperateMySql implements OperateDataBase {

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

	public void insert() {
		// TODO Auto-generated method stub
		System.setProperty("jdbc.drivers", "com.mysql.jdbc.Driver");
		String url = "jdbc:mysql://localhost:3306/abc";
		try {
			Connection conn = DriverManager.getConnection(url, "root", "sa");
			if (!conn.isClosed())
				System.out.println("数据库连接成功");
			Statement stmt = conn.createStatement();
			stmt.executeUpdate(" insert into customer (name,password) values ('xiaowang','iloveyou')");
			stmt.close();
			conn.close();
		} catch (SQLException e) {
			e.getStackTrace();
		}
	}

	public void query() {
		// TODO Auto-generated method stub
		System.setProperty("jdbc.drivers", "com.mysql.jdbc.Driver");
		String url = "jdbc:mysql://localhost:3306/abc";
		try {
			Connection conn = DriverManager.getConnection(url, "root", "sa");
			if (!conn.isClosed())
				System.out.println("数据库连接成功");
			Statement stmt = conn.createStatement();
			ResultSet rs = stmt.executeQuery("Select * from customer");
			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();
		}
	}

	public void update() {
		// TODO Auto-generated method stub
		System.setProperty("jdbc.drivers", "com.mysql.jdbc.Driver");
		String url = "jdbc:mysql://localhost:3306/abc";
		try {
			Connection conn = DriverManager.getConnection(url, "root", "sa");
			if (!conn.isClosed())
				System.out.println("数据库连接成功");
			Statement stmt = conn.createStatement();
			stmt.executeUpdate("Update customer set name='NO.1' where name='xiaowang'");
			stmt.close();
			conn.close();
		} catch (SQLException e) {
			e.getStackTrace();
		}
	}

}