operatemssql.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 OperateMSSql implements OperateDataBase {

	public void delete() {
		// TODO Auto-generated method stub
		System.setProperty("jdbc.Drivers","com.microsoft.jdbc.sqlserver.SQLServerDriver");
		String url = ("jdbc:microsoft:sqlserver://localhost:1433");
		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='xiaowang'");
			stmt.close();
			conn.close();
		} catch (SQLException e) {
			e.getStackTrace();
		}
	}

	public void insert() {
		// TODO Auto-generated method stub
		System.setProperty("jdbc.Drivers","com.microsoft.jdbc.sqlserver.SQLServerDriver");
		String url = ("jdbc:microsoft:sqlserver://localhost:1433");
		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.microsoft.jdbc.sqlserver.SQLServerDriver");
		String url = ("jdbc:microsoft:sqlserver://localhost:1433");
		try {
			Connection conn = DriverManager.getConnection(url, "root", "sa");
			if (!conn.isClosed())
				System.out.println("数据库连接成功");
			Statement stmt = conn.createStatement();
			ResultSet rs = stmt.executeQuery("select * from cusromer");
			rs.close();
			stmt.close();
			conn.close();
		} catch (SQLException e) {
			e.getStackTrace();
		}
	}

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

}