}
}
//得到连接
public static Connection getCon()
{
try {
Class.forName(drivername);
ct= DriverManager.getConnection(url, username, password);//从配置文件中读的
} catch (Exception e) {
e.printStackTrace();
}
return ct;//谁调用谁拿到Connection
}
//关闭资源函数
public static void close(ResultSet rs,Statement ps,Connection ct)
{
if(rs!=null)
{
try
{
rs.close();
}catch(Exception e)
{
}
rs=null;//使用垃圾回收
}
if(ps!=null)
{
try
{
ps.close();
}catch(SQLException e)
{
e.printStackTrace();
}
ps=null;
}
if(ct!=null)
{
try
{
ct.close();
}catch(SQLException e)
{
e.printStackTrace();
}
ct=null;
}
}
}
dbInfo.properties文件(oracle数据库)
[plain]
url=jdbc:oracle:thin:@172.0.0.1:1521:myoracle //改成自己数据库的
username=scott
driver=oracle.jdbc.driver.OracleDriver
password=123456
url=jdbc:oracle:thin:@172.0.0.1:1521:myoracle //改成自己数据库的
username=scott
driver=oracle.jdbc.driver.OracleDriver
password=123456
dbInfo.properties文件(mysql数据库)
[plain]
url=jdbc\:mysql\://localhost\:3306/dbname useUnicode\=true&characterEncoding\=utf8
username=root
driver=com.mysql.jdbc.Driver
password=root
url=jdbc\:mysql\://localhost\:3306/dbname useUnicode\=true&characterEncoding\=utf8
username=root
driver=com.mysql.jdbc.Driver
password=root
dbInfo.properties文件(sql server数据库)
[plain]
url=jdbc:sqlserver://localhost;databaseName=dbname;
username=sa
driver=com.microsoft.jdbc.sqlserver.SQLServerDriver
password=123456
url=jdbc:sqlserver://localhost;databaseName=dbname;
username=sa
driver=com.microsoft.jdbc.sqlserver.SQLServerDriver
password=123456
SqlHelper类 用于完成对数据库crud操作
[java]
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
//主要用于完成对数据库的crud操作
public class SqlHelper
{
//定义需要的变量
private static Connection ct=null;//连接
private static ResultSet rs=null;//结果
private static PreparedStatement ps=null;
public ArrayList executeQuery(String sql,String []paras)
{
ArrayList al=new ArrayList();
try {
ct=DBUtil.getCon();
ps=ct.prepareStatement(sql);
//给sql问号赋值
for (int i = 0; i < paras.length; i++)
{
ps.setString(i+1, paras[i]);
}
rs=ps.executeQuery();
//非常有用的
ResultSetMetaData rsmd=rs.getMetaData();
//用法rs可以的到有多少列
int columnNum=rsmd.getColumnCount();
//循环从a1中取出数据封装到ArrayList中
while(rs.next())
{
Object []objects=new Object[columnNum];
for(int i=0;i
objects[i]=rs.getObject(i+1); //返回对象数组
}
al.add(objects);
}
return al;
} catch (Exception e)
{
e.printStackTrace();
throw new RuntimeException(e.getMessage());
}finally
{
DBUtil.close(rs,ps,ct);
}
}
public ResultSet executeQuery(String sqlstr)
{
Stat