㈠ 請問,用c++編寫的操作資料庫函數怎麼插入blob類型的數據
如果是Oracle或者DB2,在安裝軟體之後,對應的sample子目錄下面都有各種語言連接的樣本程序,其中都包含C++語言的,也都包含blob數據類型的增刪改查的例子。
㈡ 資料庫中的BLOB欄位怎麼導入到excel中去
可以通過dbms_lob來輔助查詢:
--創建測試表
create
table
tt1
(xxname
varchar2(20),proctids
blob);
--向測試表中插入數據
insert
into
tt1
select
'a',to_blob('a001b002')
from
al;
--查詢blob欄位中含有'a001'的記錄select
xxname
from
tt1
where
mod(dbms_lob.instr(proctids,'a001'),2)=1
--刪除測試表
drop
table
tt1;
㈢ 怎麼將二進制數據存入Blob中
你哪能直接插入NSData類型char *buffer=new char[1024*1024]; //要放入的內容sqlite3_prepare( db, "insert into tb( ID, content) values( 10, ? )", -1, &stat, 0 );//准備插入數據sqlite3_bind_blob( stat, 1, buffer, strlen(buffer), NULL ); //把內容和欄位綁定CLOB和BLOB類型被用來存放大對象。BOLB表示二進制大對象,這種數據類型通過用來保存圖片,圖象,視頻等。CLOB表示字元大對象,能夠存放大量基於字元的數據。
㈣ 請教一個向oracle資料庫 blob類型欄位插入
使用to_blob函數即可 insert into table2 select pk,to_blob(value) from table1; 如果varchar2和blob存在base64的轉換關系則可用到utl_encode.base64_encode及decode函數。
㈤ 如何向各種資料庫中寫入blob類型的記錄
1.使用jdk中的方法進行傳輸。在ResultSet 中有getBlob()方法,在PreparedStatement中有setBlob()方法,所以大多數人都會嘗試setBlob
(),getBlob() 進行讀寫,或者兩個資料庫之間BLOB的傳輸。這種方法實際上是行不通的,據網上的一些資料介紹,說sun官方的文檔有些方法
都是錯誤的。
2.使用ResultSet.getBinaryStream 和PreparedStatement.setBinaryStream對BLOB進行讀寫或兩個資料庫間的傳輸。這種方法我自己嘗試過,
發現,如果BLOB中存儲的是文本文件的話,就沒問題,如果是二進制文件,傳輸就會有問題。
根據自己的經驗,以及查閱了Oracle的官方文檔,都是使用如下處理方法:
1.新建記錄,插入BLOB數據
1.1首先新建記錄的時候,使用oracle的函數插入一個空的BLOB,假設欄位A是BLOB類型的:
insert xxxtable(A,B,C) values(empty_blob(),'xxx','yyyy')
1.2後面再查詢剛才插入的記錄,然後更新BLOB,在查詢前,注意設置Connection的一個屬性:
conn.setAutoCommit(false);如果缺少這一步,可能導致fetch out of sequence等異常.
1.3 查詢剛才插入的記錄,後面要加「 for update 」,如下:
select A from xxxtable where xxx=999 for update ,如果缺少for update,可能出現row containing the LOB value is not locked
的異常
1.4 從查詢到的 BLOB欄位中,獲取blob並進行更新,代碼如下:
BLOB blob = (BLOB) rs.getBlob("A");
OutputStream os = blob.getBinaryOutputStream();
BufferedOutputStream output = new BufferedOutputStream(os);
後面再使用output.write方法將需要寫入的內容寫到output中就可以了。例如我們將一個文件寫入這個欄位中:
BufferedInputStream input = new BufferedInputStream(new File("c://hpWave.log").toURL().openStream());
byte[] buff = new byte[2048]; //用做文件寫入的緩沖
int bytesRead;
while(-1 != (bytesRead = input.read(buff, 0, buff.length))) {
output.write(buff, 0, bytesRead);
System.out.println(bytesRead);
}
上面的代碼就是從input里2k地讀取,然後寫入到output中。
1.5上面執行完畢後,記得關閉output,input,以及關閉查詢到的ResultSet
1.6最後執行conn.commit();將更新的內容提交,以及執行conn.setAutoCommit(true); 改回Connction的屬性
㈥ 怎麼把位元組數組插入資料庫的blob欄位
Java代碼實現方法
public byte[] blob2ByteArr(Blob blob) throws Exception {
byte[] b = null;
try {
if (blob != null) {
long in = 0;
b = blob.getBytes(in, (int) (blob.length()));
}
} catch (Exception e) {
e.printStackTrace();
throw new Exception("fault");
}
return b;
}
㈦ 如何往資料庫裡面寫blob數據
SqlConnection con = new SqlConnection("Server=Darkover;uid=sa;pwd=Password1;database=northwind");
SqlDataAdapter da = new SqlDataAdapter("Select * From MyImages", con);
SqlCommandBuilder MyCB = new SqlCommandBuilder(da);
DataSet ds = new DataSet("MyImages");
da.MissingSchemaAction = MissingSchemaAction.AddWithKey;
FileStream fs = new FileStream(@"C:\winnt\Gone Fishing.BMP", FileMode.OpenOrCreate, FileAccess.Read);
byte[] MyData= new byte[fs.Length];
fs.Read(MyData, 0, System.Convert.ToInt32(fs.Length));
fs.Close();
da.Fill(ds,"MyImages");
DataRow myRow;
myRow=ds.Tables["MyImages"].NewRow();
myRow["Description"] = "This would be description text";
myRow["imgField"] = MyData;
ds.Tables["MyImages"].Rows.Add(myRow);
da.Update(ds, "MyImages");
con.Close();
註:轉貼,未經測試
㈧ Hibernate向資料庫中插入Blob的類型對象時,報錯如圖,跪求指點
private function loaderHandler(event:*):void {
switch(event.type) {
case Event.COMPLETE:
trace(_loader.data.result);
break;
case Event.OPEN:
trace("open: " + event);
break;
case ProgressEvent.PROGRESS:
trace("progress: " + event);
break;
㈨ DB2中用SQL怎麼插入一個BLOB對象
要保存圖片的欄位列的類型設置成image
然後插入的時候,取它的絕對路徑
insert into 表名 values(@"C:/123.JPG")
可以用BLOB(string)函數將字元串轉化為blob再插入,如下:
create table test(c1 blob(200)); insert into test values(blob('Hello, world'));
其他的方法可能需要用別的語言來寫了,這種是在資料庫下操作
㈩ 如何將對象持久化到資料庫中BLOB
對象持久化,也就是可以把這個對象永遠的保存起來,這里的保存不僅是對象本身,還包括他的屬性和所依賴的其他類。通常,對象可以持久化到文件或者是資料庫中。我這里只介紹如何將對象存儲到資料庫中。恰巧Oracle資料庫為我們提供了這樣的方便。
在Oracle中,有一種blog的欄位類型,它是用來存儲大量的二進制數據的。我們就利用這個欄位去存儲對象信息。
首先建立一個測試表:
create table TESTBLOB
(
NAME VARCHAR2(50) not null,
CONTENT BLOB not null,
ID NUMBER(8) not null
)alter table TESTBLOB
add constraint IDFORTEST primary key (ID);
只用三個欄位,其中id是屬性,content是我們要存儲對象的欄位。
先來看看我們要存入的對象:
import java.io.Serializable;
import java.util.Date;
import java.util.List;
public class TestObject implements Serializable {
private static final long serialVersionUID = 4558876142427402513L;
/**
* @param args
*/
private String name;
private String password;
private Date date;
private List<City> cityList;
public List<City> getCityList() {
return cityList;
}
public void setCityList(List<City> cityList) {
this.cityList = cityList;
}
public Date getDate() {
return date;
}
public void setDate(Date date) {
this.date = date;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
}
記得要實現Serializable介面,可以看到這是一個包含了string,date,和list類型的對象,為了給測試增加復雜度,我們的list是另外一個對象(city)的list,如下:
import java.io.Serializable;
public class City implements Serializable{
private static final long serialVersionUID = 4558876127402513L;
private String name;
private String code;
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
}
City對象包括了城市名稱和區號。下面是主要的應用了。
import java.io.BufferedInputStream;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import oracle.sql.BLOB;
public class Test {
public static void main(String[] args) {
//創建測試用對象
City beijing = new City();
beijing.setName("北京");
beijing.setCode("010");
City shanghai = new City();
shanghai.setName("上海");
shanghai.setCode("020");
City tianjin = new City();
tianjin.setName("天津");
tianjin.setCode("021");
List<City> cityList = new ArrayList<City>();
cityList.add(beijing);
cityList.add(shanghai);
cityList.add(tianjin);
TestObject obj = new TestObject();
obj.setName("yangsq");
obj.setPassword("111");
obj.setDate(new Date());
obj.setCityList(cityList);
try{
//將對象存入blob欄位
ByteArrayOutputStream byteOut=new ByteArrayOutputStream();
ObjectOutputStream outObj=new ObjectOutputStream(byteOut);
outObj.writeObject(obj) ;
final byte[] objbytes=byteOut.toByteArray();
Class.forName("oracle.jdbc.driver.OracleDriver");
Connection con = DriverManager.getConnection(
"jdbc:oracle:thin:@***.***.***.***:1521:****", "yangsq", "yangsq");
con.setAutoCommit(false);
Statement st = con.createStatement();
st.executeUpdate("insert into TESTBLOB (ID, NAME, CONTENT) values (1, 'test1', empty_blob())");
ResultSet rs = st.executeQuery("select CONTENT from TESTBLOB where ID=1 for update");
if (rs.next()) {
BLOB blob = (BLOB) rs.getBlob("CONTENT");
OutputStream outStream = blob.getBinaryOutputStream();
outStream.write(objbytes, 0, objbytes.length);
outStream.flush();
outStream.close();
}
byteOut.close();
outObj.close();
con.commit();
//取出blob欄位中的對象,並恢復
rs = st.executeQuery("select CONTENT from TESTBLOB where ID=1");
BLOB inblob = null;
if (rs.next()) {
inblob = (BLOB) rs.getBlob("CONTENT");
}
InputStream is = inblob.getBinaryStream();
BufferedInputStream input = new BufferedInputStream(is);
byte[] buff = new byte[inblob.getBufferSize()];
while(-1 != (input.read(buff, 0, buff.length)));
ObjectInputStream in =
new ObjectInputStream(
new ByteArrayInputStream(
buff));
TestObject w3 = (TestObject)in.readObject();
System.out.println(w3.getName());
System.out.println(w3.getPassword());
System.out.println(w3.getDate());
List<City> list = w3.getCityList();
for(City city : list){
System.out.println(city.getName() + " " + city.getCode());
}
st.close();
con.close();
} catch (Exception ex) {
ex.printStackTrace();
System.exit(1);
}
}
}
代碼的藍色部分創建了要存儲的對象。再看紅色的對象寫入部分,它首先把對象轉化成二進制流的形式。對於blob欄位,我們不能簡單的在insert時插入,實際上,insert時,對於blob欄位,只能先插入一個空的blob對象empty_blob(),然後再進行"select CONTENT from TESTBLOB where ID=1 for update"對blob欄位進行更新。返回後,我們只要把對象的二進制流寫入即可。
OutputStream outStream = blob.getBinaryOutputStream();
outStream.write(objbytes, 0, objbytes.length);
需要注意的是,上述步驟必須設置con.setAutoCommit(false),否則oracle會拋出異常。
接下來,綠色的代碼是讀取資料庫中blob欄位的對象,並恢復。我們要知道的是,所有對blob欄位的操作都是二進制的,即插入時是二進制流,讀出時也是二進制流。然後用io修飾器(ObjectInputStream)去修飾。以前學習java時,感覺它的io好繁瑣啊,現在感覺還真是各有其用。下面是測試的輸出結果。
yangsq
111
Tue Mar 27 12:11:28 CST 2007
北京 010
上海 020
天津 021
需要說明一下,buff的size一定要足夠大,否則將拋出異常。在這里,我使用的是inblob.getBufferSize()來設置buff的size,這並不是一種好的方法,因為一般inblob.getBufferSize()都是32768,很可能出現異常,所以這個size最好自己設置,或系統運行時刻設置(幸好java提供數組長度的運行時刻設置)。