package com.linewell.test;
import java.io.IOException;
import java.io.OutputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
/**
* ---------------------------------------------<br>
* 说明:<br>
* <br>
* Version: 1.0<br>
* Author: [email protected] <br>
* DateTime: 2011-8-10 上午10:53:16<br>
* ---------------------------------------------<br>
* 修改版本历史<br>
* *********************************************<br>
* Author:<br>
* DateTime:<br>
* 内容:<br>
* *********************************************<br>
*/
public class TestJdbc {
public static void main(String[] args){
Connection conn=null;
Statement stmt=null;
ResultSet rs=null;
//String conStr="oracle.jdbc.driver.OracleDriver";
String url="jdbc:mysql://localhost:3306/msginfo";//所有用户建的表都在orcl这个数据库里
try {
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
System.out.println("class not success");
e.printStackTrace();
}
try { //System.out.println("11ffff");
conn=DriverManager.getConnection(url, "root", "root");
System.out.println("11ffff");
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
//String sql="insert into tel_xing(xing_unid,xing_name,xing_country,xing_password,xing_images)values('1','lin','china','123',empty_blob())";
try {
OutputStream outStream=null;
//System.out.println("ffff");
stmt=conn.createStatement();
//stmt.executeUpdate(sql);
rs=stmt.executeQuery("select xing_images from tel_xing where xing_unid='1' for update");
if (rs.next())
{
//得到java.sql.Blob对象后强制转换为oracle.sql.BLOB
// oracle.sql.BLOB blob = (oracle.sql.BLOB) rs.getBlob("xing_images");
//outStream = blob.getBinaryOutputStream();
//data是传入的byte数组,定义:byte[] data
byte[] data={1,1,1,1};
try {
outStream.write(data, 0, data.length);
System.out.println(outStream);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
try {
outStream.flush();
outStream.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
conn.commit();
/*rs=stmt.executeQuery(sql);
while(rs.next()){
// System.out.println("ffff11");
System.out.println(rs.getString("user_unid"));
System.out.println(rs.getString("user_name"));
}*/
} catch (SQLException e) {
// TODO Auto-generated catch block
System.out.println("lj no success");
e.printStackTrace();
}
finally{ try {
if(rs!=null){
rs.close();
rs=null;
}
if(stmt!=null)
{
stmt.close();
stmt=null;
}
if(conn!=null){
conn.close();
conn=null;
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}