返回首页

gbase数据、南大通用产品文档:GBase8a集群所有节点上进行本地文件加载

更新日期:2024年09月11日

使用file://+abs_path 指定file_list 信息。多个file://+abs_path 之间使用逗号分隔。
URL 的定义格式如下:
file:// +abs_path[,file:// +abs_path]
示例
LOAD DATA INFILE ‘file:///var/ftp/pub/line5*.tbl, file:///home/gbase/lineitem.*’
INTO TABLE test.t FIELDS TERMINATED BY ‘|’;

Jiffies
Host CPU busy time ratio
:

本示例实现了使用SELECT LAST_INSERT_ID()获取AUTO_INCREMENT 列的值。
示例如下:
package com.gbase.jdbc.simple;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

GBase UP 产品手册 6 应用开发指南
文档版本04(2021-04-21) 南大通用数据技术股份有限公司 1103

public class SampleLastInsertID {



private
static
final
String
URL
=
"jdbc:gbase://192.168.111.95:5258/test?user=sysdba&password=";

public static void main(String[] args) {


try {



(new SampleLastInsertID()).test();


} catch (Exception ex) {



}

}


public void test() throws Exception {


Connection conn = null;


try {



Class.forName("com.gbase.jdbc.Driver").newInstance();



conn = DriverManager.getConnection(URL);




Statement stmt = null;



ResultSet rs = null;



try {




// 创建Statement 对象




stmt = conn.createStatement();









// 创建表




stmt.executeUpdate("DROP TABLE IF EXISTS autoIncTutorial");




stmt.executeUpdate("CREATE TABLE autoIncTutorial ("






+ "priKey INT NOT NULL AUTO_INCREMENT, "






+ "dataField VARCHAR(64), PRIMARY KEY (priKey))");









// 插入一条数据






stmt.executeUpdate("INSERT INTO autoIncTutorial (dataField) "






+ "values ('Can I Get the Auto Increment Field?')");









// 使用LAST_INSERT_ID()获取自增一字段值




int autoIncKeyFromFunc = -1;




rs = stmt.executeQuery("SELECT LAST_INSERT_ID()");




if (rs.next()) {





autoIncKeyFromFunc = rs.getInt(1);




} else {










}




rs.close();

GBase UP 产品手册 6 应用开发指南
文档版本04(2021-04-21) 南大通用数据技术股份有限公司 1104




System.out.println("Key returned from "






+ "'SELECT LAST_INSERT_ID()': " + autoIncKeyFromFunc);



} finally {




if (rs != null) {





try {






rs.close();





} catch (SQLException ex) {












}




}




if (stmt != null) {





try {






stmt.close();





} catch (SQLException ex) {












}




}



}


} catch (SQLException ex) {



// 处理错误



System.out.println("SQLException: " + ex.getMessage());



System.out.println("SQLState: " + ex.getSQLState());



System.out.println("VendorError: " + ex.getErrorCode());


} finally {



conn.close();


}

}
}