java 读取文件 和 执行SQL脚本 (支持中文)

读文件操作应用

执行SQL脚本文件

/**
*执行SQL脚本文件
*@parampath
*@throwsSQLException
*@throwsClassNotFoundException
*/
publicvoidexeSQLScript(Stringpath)throwsSQLException,ClassNotFoundException
{
//建立数据库连接
if(this.conn==null||conn.isClosed())
openConn();
stmt=this.conn.createStatement();
//读取文件
try
{
InputStreamr=newFileInputStream(path);
ByteArrayOutputStreambyteout=newByteArrayOutputStream();
bytetmp[]=newbyte[256];
bytecontext[];
inti=0;
while((i=r.read(tmp))!=-1)
{
byteout.write(tmp);
}
context=byteout.toByteArray();
Stringstr=newString(context,"UTF-8");
//分隔行
Stringstra[]=str.split("\\;");
for(intn=0;n<stra.length;n++)
{
//System.out.println(stra[n]);
stmt.addBatch(stra[n]);
}
stmt.executeBatch();
}
catch(Exceptione)
{
//TODO:handleexception
}
}

读文件操作示例

packagewh;

importjava.io.BufferedReader;
importjava.io.ByteArrayOutputStream;
importjava.io.File;
importjava.io.FileInputStream;
importjava.io.FileReader;
importjava.io.FilterInputStream;
importjava.io.InputStream;

publicclassStream
{
publicstaticvoidmain(String[]args)
{
try
{
InputStreamr=newFileInputStream("c:/a.txt");
ByteArrayOutputStreambyteout=newByteArrayOutputStream();
bytetmp[]=newbyte[256];
bytecontext[];
inti=0;
while((i=r.read(tmp))!=-1)
{
byteout.write(tmp);
}
context=byteout.toByteArray();
Stringstr=newString(context,"UTF-8");
//分隔行
Stringstra[]=str.split("");
for(intn=0;n<stra.length;n++)
{
System.out.println(stra[n]+"++++");
}
//System.out.println(str);
}catch(Exceptione)
{
//TODO:handleexception
}
}
}