JDBC之Statement

package com.saas.jdbc;

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

/**
 * 此类是对连接数据库的基本操作，以及基本步骤
 * 
 * 
 * 
 * 思路:
 *  1) 加载驱动程序
 *  2) 连接数据库
 *  3) 创建语句
 *  4) 执行语句
 *  5) 关闭连接
 *  
 * @author Administrator
 * 
 * 此类主要是对Statement类的举例使用
 * 
 * 写代码，做任何事情都需要专业化，比别人多做一步，多走一步。细节决定成败
 */

public class JDBCTestDemo01 {
	
	public static String _URL="jdbc:mysql://127.0.0.1:3306/shopping_thpad_com?useUnicode=true&characterEncoding=UTF-8&useOldAliasMetadataBehavior=true";
	
	public static String _LOGIN_NAME="root";
	
	public static String _LOGIN_PASSWORD="123456";
	
	public void conectDataBase() {
	
		Connection connect = null;
		Statement stmt = null;
		ResultSet rs = null ;
		try {
			//加载驱动，注册驱动 两种方法
			Class.forName("com.mysql.jdbc.Driver");
			//DriverManager.registerDriver(new com.mysql.jdbc.Driver()); 
			connect = DriverManager.getConnection(_URL, _LOGIN_NAME, _LOGIN_PASSWORD);
			
			connect.setAutoCommit(false);
			
			stmt = connect.createStatement();
			
			//添加
			Calendar cal1 = Calendar.getInstance();
			String _insert_sql = "insert into item_spec(item_spec_id,name,remarks) " +
					"values('"+cal1.getTimeInMillis()+"','好的','测试测试测试')";
			int iResult = stmt.executeUpdate(_insert_sql);
			
			System.out.println("=========="+iResult);
			Calendar cal2 = Calendar.getInstance();
			String _insert_sql_1 = "insert into item_spec(item_spec_id,name,remarks) " +
			"values('"+(cal2.getTimeInMillis()+1)+"','好1111的','测试测试测试')";
			boolean iResult1 = stmt.execute(_insert_sql_1);
			System.out.println("=========="+iResult1);
			
			//修改
			
			String edit_sql = "update item_spec set remarks='test' where item_spec_id='10003'";
			int iResult3 = stmt.executeUpdate(edit_sql);
			System.out.println("=========="+iResult3);
			
			String edit_sql2= "update item_spec set remarks='testtest' where item_spec_id='20003'";
			boolean result1=stmt.execute(edit_sql2);
			System.out.println("=========="+result1);
			
			//删除
			String delete_sql ="delete from item_spec where item_spec_id='10003'";
			boolean delete_sql1=stmt.execute(delete_sql);
			System.out.println("=========="+delete_sql1);
			// 查询
			rs = stmt.executeQuery("select * from item_spec ");
			
			/**
			 * 查询语句返回的是结果集，结果集里面的游标指向头部,使用next()方法可以判断是否有数据
			 */
			
			//在编码中尽量抓抛出异常 , 防止和数据库连接的时候数据库资源浪费。
			while (rs.next()) {
				System.out.print("------"+rs.getString(1));
				System.out.print("------"+rs.getString(2));
				System.out.println("-------"+rs.getString(3));
			}
			connect.setAutoCommit(true);
			
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			//报告日志记录log中
		} catch(SQLException e) {
			e.printStackTrace();
			//报告日志记录log中
		} finally {
			try  {
				if(null!=rs) {
					rs.close();	
					rs = null ; //垃圾收集器收集
				}
				if(null!=stmt) {
					stmt.close();	
					stmt=null ; //垃圾收集器收集
				}
				if(null!=connect) {
					connect.close();	
					connect = null; //垃圾收集器收集
				}
			}
			catch(SQLException e) {
				e.printStackTrace();
			}
		}
		
	}
	
	public static void main(String []args) {
		JDBCTestDemo01 test = new JDBCTestDemo01();
		test.conectDataBase();
		
	}
}