JDBC编程学习笔记（二)——执行SQL语句 ExecuteSQL.java

本文主要介绍使用Statement的execute()方法来执行任意的SQL语句，并列出你在运行该程序中可能会遇到的一系列问题，我只能将我在运行中遇到的问题描述，希望对你有所帮助。首先，你需要创建一个配置数据库的配置文件，如下图：



文件的内容如下图：



内容主要是MySQL的url，以及用户帐号和密码，只要有这配置文件，我们就不需要在代码内部改，只需加载配置文件即可。以下附上源码：

import java.util.*;
import java.sql.*;
import java.io.*;

public class ExecuteSQL
{
private String driver;
private String url;
private String user;
private String pass;
Connection conn;
Statement stmt;
ResultSet rs;
public void initParam(String paramFile) throws Exception
{
//使用Properties类来加载属性文件
Properties props=new Properties();
props.load(new FileInputStream(paramFile));
driver=props.getProperty("driver");
url=props.getProperty("url");
user=props.getProperty("user");
pass=props.getProperty("pass");
}
public void executeSql(String sql) throws Exception
{
try
{
//加载驱动
Class.forName(driver);
//获取数据库连接
conn=DriverManager.getConnection(url,user,pass);
//使用Connection来创建一个Statment对象
stmt=conn.createStatement();
//执行SQL,返回boolean值表示是否包含ResultSet
boolean hasResultSet=stmt.execute(sql);
//如果执行后有ResultSet结果集
if(hasResultSet)
{

//获取结果集
rs = stmt.getResultSet();
//ResultSetMetaData是用于分析结果集的元数据接口
ResultSetMetaData rsmd = rs.getMetaData();
int columnCount = rsmd.getColumnCount();
//迭代输出ResultSet对象
while(rs.next())
{
//依次输出每列的值
for(int i=0;i<columnCount;i++)
{
System.out.print(rs.getString(i+1)+"\t");
}
System.out.print("\n");
}

}
else
{
System.out.println("该SQL语句影响的记录有"+stmt.getUpdateCount()+"条");
}
}
//使用finally块来关闭数据库资源
finally
{
if (rs != null)
{
rs.close();
}
if (stmt != null)
{
stmt.close();
}
if (conn != null)
{
conn.close();
}
}
}
public static void main(String[] args) throws Exception
{
ExecuteSQL es=new ExecuteSQL();
es.initParam("D:/mysql.ini");
System.out.println("------执行删除表的DDL语句-----");
es.executeSql("drop table if exists my_test");
System.out.println("------执行建表的DDL语句-----");
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 student_name from student_table");
System.out.println("------执行查询数据的查询语句-----");
es.executeSql("select*from my_test");
}
}

编译没有错误，你会很高兴，结果一运行，结果可能如下图......................



这主要又是数据库的字符编码问题，具体我也不是很清楚，请大家看博客http://blog.csdn.net/geilivablemental/article/details/45034229.....我是看了之后，然后再修改，即在源码上加入下列两条语句：



然后就......



可以了...........