将文件写入数据库

Question

最近从.net转到j2ee,原来有这样一段c#代码,java下面不知怎么写,大家帮忙看一些,谢谢.
int  index=path.LastIndexOf("\\"); 
string filename=path.Substring(index+1);
string filetype=((HtmlInputFile)Controls[1]).PostedFile.ContentType;
string Sname=System.Guid.NewGuid().ToString();//上传到服务器的临时文件名
string Spath="../..\\tempdoc\\";//服务器上的目录名
Spath=AppDomain.CurrentDomain.GetData("APPBASE").ToString()+Spath;//获取当前应用程序目录
System.IO.FileInfo check = new FileInfo(Spath);
if(!check.Exists)//判断指定目录是否存在
{
check.Directory.Create();
}
Spath+=Sname;
((HtmlInputFile)Controls[1]).PostedFile.SaveAs(Spath);//将附件存到服务器的临时文件中
FileStream fs=new FileStream(Spath,FileMode.OpenOrCreate,FileAccess.Read);
byte [] arrfile=new byte[fs.Length];
fs.Read(arrfile,0,Convert.ToInt32(fs.Length));//取出文件内容
IDbConnection con = new OracleConnection(connectionstring);
con.open()
mysql="insert into sys_file(fileid,filename,content,filetype) values(xl_sys_file.nextval,'"+filename+"',:fj,'"+filetype+"')";
IDbCommand  mycom =new OracleCommand(con,mysql)
System.Data.IDataParameter parm = new OracleParameter("fj",OracleType.LongRaw);
parm.Value=arrfile;//字节数组,从文件读出的二进制流
mycom.Parameters.Add(parm);
mycom.ExecuteNonQuery();
con.close()变成java应该怎么写啊,数据库用的oracle,服务器用的weblogic,数据库连接使用的jndi.

Answer 1

oracle自带一个例子：/* 
 * This sample demonstrate basic Lob support.
 * (insert, fetch rows of BLOB and CLOB)
 *
 * It 1. drops, create, and populates table basic_lob_table
 *       with blob, clob data types in the database.
 *    2. Please use jdk1.2 or later version and classes12.zip 
 */import java.sql.*;
import java.io.*;
import java.util.*;// Importing the Oracle Jdbc driver package makes
// the code more readable
import oracle.jdbc.*;//needed for new CLOB and BLOB classes
import oracle.sql.*;public class LobExample
{
  public static void main (String args [])
       throws Exception
  {
    // Register the Oracle JDBC driver
    DriverManager.registerDriver
                   (new oracle.jdbc.OracleDriver());    String url = "jdbc:oracle:oci8:@";
    try {
      String url1 = System.getProperty("JDBC_URL");
      if (url1 != null)
        url = url1;
    } catch (Exception e) {
      // If there is any security exception, ignore it
      // and use the default
    }    // Connect to the database
    Connection conn =
      DriverManager.getConnection (url, "hr", "hr");    // It's faster when auto commit is off
    conn.setAutoCommit (false);    // Create a Statement
    Statement stmt = conn.createStatement ();    try
    {
      stmt.execute ("drop table basic_lob_table");
    }
    catch (SQLException e)
    {
      // An exception could be raised here if the
      // table did not exist already.
    }    // Create a table containing a BLOB and a CLOB
    stmt.execute ("create table basic_lob_table (x varchar2 (30), " +
                  "b blob, c clob)");
    
    // Populate the table
    stmt.execute ("insert into basic_lob_table values ('one', " +
                  "'010101010101010101010101010101', " +
                  "'onetwothreefour')");
    stmt.execute ("insert into basic_lob_table values ('two', " +
                  "'0202020202020202020202020202', " +
                  "'twothreefourfivesix')");
    
    System.out.println ("Dumping lobs");    // Select the lobs. Since the Lob contents will be modified,
    // we need to lock the table rows. This can be done by doing
    // "select ... for update", but we don't need to select for
    // update here because we have "autocommit" turned off and
    // the previous "create table" statement already have the
    // whole table locked.
    ResultSet rset = stmt.executeQuery
                          ("select * from basic_lob_table");
    while (rset.next ())
    {
      // Get the lobs
      BLOB blob = ((OracleResultSet)rset).getBLOB (2);
      CLOB clob = ((OracleResultSet)rset).getCLOB (3);      // Print the lob contents
      dumpBlob (blob);
      dumpClob (clob);      // Change the lob contents
      fillClob (clob, 2000);
      fillBlob (blob, 4000);
    }    System.out.println ("Dumping lobs again");    rset = stmt.executeQuery
                ("select * from basic_lob_table");
    while (rset.next ())
    {
      // Get the lobs
      BLOB blob = ((OracleResultSet)rset).getBLOB (2);
      CLOB clob = ((OracleResultSet)rset).getCLOB (3);      // Print the lobs contents
      dumpBlob (blob);
      dumpClob (clob);
    }
    // Close all resources
    rset.close();
    stmt.close();
    conn.close(); 
  }  // Utility function to dump Clob contents
  static void dumpClob (CLOB clob)
    throws Exception
  {
    // get character stream to retrieve clob data
    Reader instream = clob.getCharacterStream();    // create temporary buffer for read
    char[] buffer = new char[10];    // length of characters read
    int length = 0;    // fetch data  
    while ((length = instream.read(buffer)) != -1)
    {
      System.out.print("Read " + length + " chars: ");      for (int i=0; i<length; i++)
        System.out.print(buffer[i]);
      System.out.println();
    }    // Close input stream
    instream.close();
  }  // Utility function to dump Blob contents
  static void dumpBlob (BLOB blob)
    throws Exception
  {
    // Get binary output stream to retrieve blob data
    InputStream instream = blob.getBinaryStream();    // Create temporary buffer for read
    byte[] buffer = new byte[10];    // length of bytes read
    int length = 0;    // Fetch data  
    while ((length = instream.read(buffer)) != -1)
    {
      System.out.print("Read " + length + " bytes: ");      for (int i=0; i<length; i++)
        System.out.print(buffer[i]+" ");
      System.out.println();
    }    // Close input stream
    instream.close();
  }  // Utility function to put data in a Clob
  static void fillClob (CLOB clob, long length)
    throws Exception
  {
    Writer outstream = clob.getCharacterOutputStream();    int i = 0;
    int chunk = 10;    while (i < length)
    {
      outstream.write(i + "hello world", 0, chunk);      i += chunk;
      if (length - i < chunk)
chunk = (int) length - i;
    }
    outstream.close();
  }  // Utility function to put data in a Blob
  static void fillBlob (BLOB blob, long length)
    throws Exception
  {
    OutputStream outstream =
                 blob.getBinaryOutputStream();    int i = 0;
    int chunk = 10;    byte [] data = { 1, 2, 3, 4, 5, 6, 7, 8, 9, 10 };    while (i < length)
    {
      data [0] = (byte)i;
      outstream.write(data, 0, chunk);      i += chunk;
      if (length - i < chunk)
chunk = (int) length - i;
    }
    outstream.close();
  }
}

Answer 2

我用的longrow类型，还有jndi的连接串要是得到连接对象的话应该怎么写啊？

Answer 3

Connection conn = DriverManager.getConnection (url, "usr", "pwd");

Answer 4

这个url是个什么东西呢?我现在只有一个jndi数据源的名称

Answer 5

uml是数据库连接字符串
用jndi的话这样写：
Context initCtx=new InitialContext();
DataSource db = (DataSource)initCtx.lookup("java:comp/env/jdbc/JCC");
Connection conn = db.getConnection();

Answer 6

Context initCtx=new InitialContext();
DataSource db = (DataSource)initCtx.lookup("java:comp/env/jdbc/JCC");
Connection conn = db.getConnection();那我的数据源名称放到哪里呢?