package com.shanxi.weixin;

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

public class JDBCDemo {

	public static void main(String[] args) {
		
		try {
			//1、加载驱动类
			Class.forName("com.mysql.jdbc.Driver");
	  		//2、获取数据库连接对象connection //jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8
	  		Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test4","root", "root");
	  		//System.out.println(conn);
	  		//3、通过connection 获取操作数据库的对象  statement
	  		Statement sta = conn.createStatement();
	  		//4、使用statement对象操作数据库完成相应的业务
	  			//2.1  将数据库的事务提交方式设为手动
	  		conn.setAutoCommit(false);
	  		int a = sta.executeUpdate("delete from company where company_id in (9,10)");
	  		int b = sta.executeUpdate("delete from company where company_id = 1 ");
	  		int c = sta.executeUpdate("insert into company(company_id,company_name) values(null,'ccc')");
	  		int d = sta.executeUpdate("insert into company(company_id,company_name) values(3,'ddd')");
	  		//ResultSet rs = sta.executeQuery("select * from people");
		  		//2.2 提交事务单元
		  	conn.commit();
	  		//5、处理结果集
	  		System.out.println(a + b + c + d);
	  		
//	  		while(rs.next()){
//	  			System.out.println(rs.getString("name")+"---"+rs.getString("idcard"));
//	  		}
	  		//6、关闭资源，释放空间。
	  		if(conn!=null){
	  			conn.close();
	  		}
		}catch (ClassNotFoundException e) {
			e.printStackTrace();
		}catch (SQLException e) {
			e.printStackTrace();
		}
	}
}

package com.shanxi.weixin;

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

public class JDBCDemo2 {

	public static void main(String[] args) {
		
		try {
			//1、加载驱动类
			Class.forName("oracle.jdbc.driver.OracleDriver");
	  		Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@192.168.42.43:1521:orcl","gao", "gao");
	  		//System.out.println(conn);
	  		//3、通过connection 获取操作数据库的对象  statement
	  		Statement sta = conn.createStatement();
	  		//4、使用statement对象操作数据库完成相应的业务
	  		//ResultSet rs = sta.executeQuery("select * from stu");
	  		int a =sta.executeUpdate("delete from stu where s_id = 20");
	  		int b =sta.executeUpdate("insert into stu(s_id,s_name) values(9,'aaa')");
	  		//5、处理结果集
//	  		while(rs.next()){
//	  			System.out.println(rs.getString("s_name")+"---"+rs.getString("s_addr"));
//	  		}
	  		System.out.println(a + b);
	  		//6、关闭资源，释放空间。
	  		if(conn!=null){
	  			conn.close();
	  		}
		}catch (ClassNotFoundException e) {
			e.printStackTrace();
		}catch (SQLException e) {
			e.printStackTrace();
		}
	}
}

public class JdbcDemo1 {

	public static void main(String[] args) {
		// TODO Auto-generated method stub
		try {
			//1、加载驱动类
			Class.forName("com.mysql.jdbc.Driver");
	  		//2、获取数据库连接对象connection //jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8
	  		Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/wordpress","root", "");
	  		//System.out.println(conn);
	  		//3、通过connection 获取操作数据库的对象  statement
	  		Statement sta = conn.createStatement();
	  		//4、使用statement对象操作数据库完成相应的业务
	  		ResultSet rs = sta.executeQuery("select * from wp_users");
	  		//5、处理结果集
	  		while(rs.next()){
	  			System.out.println(rs.getString("user_login")+"---"+rs.getString("user_pass"));
	  		}
	  		//6、关闭资源，释放空间。
	  		if(conn!=null){
	  			conn.close();
	  		}
		}catch (ClassNotFoundException e) {
			e.printStackTrace();
		}catch (SQLException e) {
			e.printStackTrace();
		}
	}

}

package com.shanxi.weixin;

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

public class JDBCDemo2 {

	public static void main(String[] args) {
		
		try {
			//1、加载驱动类
			Class.forName("oracle.jdbc.driver.OracleDriver");
	  		Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@192.168.42.43:1521:orcl","gao", "gao");
	  		//System.out.println(conn);
	  		//3、通过connection 获取操作数据库的对象  statement
	  		Statement sta = conn.createStatement();
	  		//4、使用statement对象操作数据库完成相应的业务
	  		//ResultSet rs = sta.executeQuery("select * from stu");
	  		int a =sta.executeUpdate("delete from stu where s_id = 20");
	  		int b =sta.executeUpdate("insert into stu(s_id,s_name) values(9,'aaa')");
	  		//5、处理结果集
//	  		while(rs.next()){
//	  			System.out.println(rs.getString("s_name")+"---"+rs.getString("s_addr"));
//	  		}
	  		System.out.println(a + b);
	  		//6、关闭资源，释放空间。
	  		if(conn!=null){
	  			conn.close();
	  		}
		}catch (ClassNotFoundException e) {
			e.printStackTrace();
		}catch (SQLException e) {
			e.printStackTrace();
		}
	}
}

package com.shanxi.weixin;

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 JDBCDemo4 {

	public static void main(String[] args) {
		
		try {
			Class.forName("com.mysql.jdbc.Driver");
	  		Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test4?useUnicode=true&characterEncoding=utf8","root", "root");
	  		String sql = "insert into people(name,age,sex) values(?,?,?)";
	  		PreparedStatement ps = conn.prepareStatement(sql);
	  		ps.setString(1, "mike");
	  		ps.setString(3, "boy");
	  		ps.setInt(2, 20);
	  		int a = ps.executeUpdate();
	  		System.out.println(a);
	  		if(conn!=null){
	  			conn.close();
	  		}
	  		                                          
		}catch (ClassNotFoundException e) {
			e.printStackTrace();
		}catch (SQLException e) {
			e.printStackTrace();
		}
	}
}

package com.shanxi.weixin;

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 JDBCDemo3 {

	public static void main(String[] args) {
		
		try {
			Class.forName("com.mysql.jdbc.Driver");
	  		Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test4?useUnicode=true&characterEncoding=utf8","root", "root");
	  		//获取预编译对象  preparstatement
	  		PreparedStatement ps = conn.prepareStatement("select * from people where id = ? ");
	  		//如果预编译对象绑定的sql中含有参数。那么在操作数据库之前需将参数依次传入
	  		ps.setInt(1, 9);
	  		//执行对应的操作，获得对应结果集
	  		ResultSet rs = ps.executeQuery();
	  		while(rs.next()){
	  			System.out.println(rs.getString("name"));
	  		}
	  		if(conn!=null){
	  			conn.close();
	  		}
	  		
		}catch (ClassNotFoundException e) {
			e.printStackTrace();
		}catch (SQLException e) {
			e.printStackTrace();
		}
	}
}

package com.shanxi.weixin;

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 JDBCDemo5 {

	public static void main(String[] args) {
		
		try {
			Class.forName("com.mysql.jdbc.Driver");
	  		Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test4?useUnicode=true&characterEncoding=utf8","root", "root");
	  		String sql = "insert into people(name,age,sex) values(?,?,?)";
	  		//Statement sta = conn.createStatement();
	  		
	  		//打开一个预编译对象  同时绑定sql
	  		PreparedStatement ps = conn.prepareStatement(sql);
	  		ps.setString(1, "bob");
	  		ps.setString(3, "boy");
	  		ps.setInt(2, 22);
	  		//将本条sql处理 加入批处理
	  		ps.addBatch();
	  		
	  		ps.setString(1, "mary");
	  		ps.setString(3, "girl");
	  		ps.setInt(2, 18);
	  		//将重新设置参数后的预编译sql继续加入批处理
	  		ps.addBatch();
	  		//同时也可以绑定多条静态sql
	  		ps.addBatch("insert into people(name,age,sex) values('rose',19,'girl')");
	  		//执行批处理任务
	  		int[] counts = ps.executeBatch();
	  		ps.clearBatch();
	  		for (int i : counts) {
				System.out.println(i);
			}
	  		if(conn!=null){
	  			conn.close();
	  		}                                      
		}catch (ClassNotFoundException e) {
			e.printStackTrace();
		}catch (SQLException e) {
			e.printStackTrace();
		}
	}
}