D KuduAPI之新增資料

2021-09-26 22:21:56 字數 2767 閱讀 8236

kuduclient提供的三種方式給我們插入資料,直接看**

1. 手動重新整理資料

private

static

final logger log = logge***ctory.

getlogger

(inserttable.

class);

private

static ******dateformat sdf =

new******dateformat

("yyyy");

private

static

final

int bufferspace =

100000

;//閾值

private

static column column = columnprop.

getcolumn()

;private

static prop prop =

newprop()

;/**

* 手動提交

* @param startid

* @param endid

* @throws kuduexception

*/public

static

void

insertbymanual

(int startid,

int endid)

throws kuduexception

}//最終提交一次,保證不漏資料

if(count >0)

}

2. 自動重新整理
private

static

final logger log = logge***ctory.

getlogger

(inserttable.

class);

private

static ******dateformat sdf =

new******dateformat

("yyyy");

private

static

final

int bufferspace =

100000

;//閾值

private

static column column = columnprop.

getcolumn()

;private

static prop prop =

newprop()

;/**

* 自動提交

* @param startid

* @param endid

* @throws kuduexception

*/public

static

void

insertbyautu

(int startid,

int endid)

throws kuduexception

}

3. 手動 + 自動
private

static

final logger log = logge***ctory.

getlogger

(inserttable.

class);

private

static ******dateformat sdf =

new******dateformat

("yyyy");

private

static

final

int bufferspace =

100000

;//閾值

private

static column column = columnprop.

getcolumn()

;private

static prop prop =

newprop()

;/**

* 手動 + 自動重新整理

** @param startid

* @param endid

* @throws exception

*/public

static

void

insertbyall

(int startid,

int endid)

throws exception }}

// 對於手工提交, 保證完成最後的提交

if(sessionconfiguration.flushmode.auto_flush_background == sessionconfiguration.flushmode.auto_flush_background && count >0)

// 對於後台自動提交, 必須保證完成最後的提交, 並保證有錯誤時能丟擲異常

if(sessionconfiguration.flushmode.auto_flush_background == sessionconfiguration.flushmode.auto_flush_background)

stringbuilder errormessage =

newstringbuilder()

;if(error.

getrowerrors()

.length >0)

}throw

newexception

(errormessage.

tostring()

);}}

}

PHP MySQLi STMT新增資料

php mysqli stmt 新增資料 預編譯 1.建立mysqli物件 mysqli new mysqli localhost root 1234 test 2.建立預編譯物件 sql insert into user1 name,password,email,age values mysqli...

ExtJs gridPanel新增資料

向gridpanel新增資料 資料模型 ext define xx xxmodel 一 當gridpanel讀取的是資料庫的資訊時me.store ext.create ext.data.store listeners load function store,records,successful,e...

JDBC新增資料

使用drivergetconnect 取得的連線物件是connection型別,如果要對資料庫中的資料進行操作,我們還需要該物件取得另乙個物件來傳送sql語句,要取得這個傳送sql語句的物件我們需要用到connnetion中的這些方法 void close 關閉資料庫連線,使用完資料庫連線之後必須關...