JDBC连接mysql

加入  mysql的驱动jar:  mysql-connector-java-5.1.25-bin.jar
mysql.ini 的内容

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3306/mysql
user=root
pass=123456
initialSize=5
maxActive=20
minIdle=2
maxStatements=180

package com.enhance.jdbc;

import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.Statement;
import java.util.Properties;

public class ExecuteSql {
	
	private String driver;
	private String url;
	private String user;
	private String pass;
	private Connection conn;
	private Statement stmt;
	private ResultSet rs;
	public void initParam(String paramFile) throws Exception{
		Properties prop=new Properties();
		prop.load(new FileInputStream(paramFile));
		driver=prop.getProperty("driver");
		url=prop.getProperty("url");
		user=prop.getProperty("user");
		pass=prop.getProperty("pass");
	}
	
	//使用execute 执行 sql, true 表示select 返回的 resultSet ,false:表示受影响的行数
	public void executeSql(String sql) throws Exception{
		
		try{
			Class.forName(driver);
			conn=DriverManager.getConnection(url,user,pass);
			stmt=conn.createStatement();
			
			boolean hasResultSet=stmt.execute(sql);
			
			if(hasResultSet){
				rs=stmt.getResultSet();
				//ResultSetMetaData 用于分析结果集元数据接口
				ResultSetMetaData rsmd=rs.getMetaData();
				int columnCount=rsmd.getColumnCount();
				while(rs.next()){
					
					for(int i=0;i<columnCount;i++){
						System.out.print(rsmd.getColumnName(i+1)+"---\t--"+rsmd.getColumnType(i+1)+"---\t--"+rs.getString(i+1)+"\t----|-");
					}
					System.out.println();
				}
			}else{
				System.out.println("该SQL语句影响的记录有"+stmt.getUpdateCount()+"条");
			}
		
		}finally{
			if(rs!=null)
				rs.close();
			if(stmt!=null)
				stmt.close();
			if(conn!=null)
				conn.close();
		}
	}
	
	
	public static void main(String[] args) throws Exception {
		// TODO Auto-generated method stub
		ExecuteSql es=new ExecuteSql();
		es.initParam("src/mysql.ini");
		//System.out.println("----执行删除表数据的DDL语句----");
		//es.executeSql("truncate table jdbc_test");
		System.out.println("----执行删除表的DDL语句----");
		es.executeSql("drop table if exists jdbc_test");
		System.out.println("----执行删除表的DDL语句----");
		es.executeSql("drop table if exists my_test");
		es.executeSql("create table my_test"
				+ "( test_id int auto_increment primary key,"
				+ "test_name varchar(255))");
		
		System.out.println("----执行插入数据的DML语句----");
		es.executeSql("insert into my_test(test_name)"
				+ " select user from user");
		
		System.out.println("----执行插入数据的查询语句----");
		es.executeSql("select host,user,password from user");
		
		
	}

}