import com.fujitsu.shun.ShunConnection;
import com.fujitsu.shun.ShunPreparedKey;
import com.fujitsu.shun.ShunResultSet;
import com.fujitsu.shun.common.ShunException;
/*** Search data using direct access key ***/
public class DirectAccessSample {
public static void main(String[] args) {
ShunConnection con = null;
ShunPreparedKey keystmt = null;
ShunResultSet rs = null;
try {
// Direct access key name
String sCoursKeyName = "key";
// Direct access key
String key = "0001";
// Return expression
String sCourseReturn = "/";
// Create ShunConnection object
// Host name for the connection destination:DirSvr1,
// Port number:33101,
// If the Shunsaku File name is shunsakuFile1
con = new ShunConnection("DirSvr1", 33101, "shunsakuFile1");
// Create ShunPreparedKey object for searching data
keystmt = con.prepareSearchKey(sCoursKeyName, sCourseReturn);
// Add the direct acess key to be searched
keystmt.add(key);
// Execute search and create ShunResultSet object
rs = keystmt.searchByKey();
// Obtain number of hits
int iHitNum = rs.getHitCount();
// Data counter
int iDataCounter = 1;
System.out.println("Number of hits = " + iHitNum);
// Obtain the data corresponding to the search conditions one item at a time
while (rs.next()) {
System.out.println("[Result] Item No." + iDataCounter);
System.out.println("Direct access key:" + rs.getKey());
System.out.println("Data :");
System.out.println(rs.getString());
iDataCounter++;
}
rs.close();
keystmt.close();
con.close();
}
// Processing to perform if an error occurs while the application is running
catch (ShunException ex) {
int errorLevel = ex.getErrLevel();
switch (errorLevel) {
case ShunException.SHUN_ERROR:
System.out.println("Error level :SHUN_ERROR");
break;
case ShunException.SHUN_ERROR_CONNECTION_TERMINATED:
System.out.println("Error level :SHUN_ERROR_CONNECTION_TERMINATED");
break;
}
System.out.println("Error message:" + ex.getMessage());
ex.printStackTrace();
}
catch (Exception ex) {
System.out.println("Error message:" + ex.getMessage());
ex.printStackTrace();
}
// Recovery procedure in the event of an error
finally {
try {
if(rs != null) rs.close();
}
catch (ShunException ex) {
int errorLevel = ex.getErrLevel();
switch (errorLevel) {
case ShunException.SHUN_ERROR:
System.out.println("Error level :SHUN_ERROR");
break;
case ShunException.SHUN_ERROR_CONNECTION_TERMINATED:
System.out.println("Error level :SHUN_ERROR_CONNECTION_TERMINATED");
break;
}
System.out.println("Error message:" + ex.getMessage());
ex.printStackTrace();
}
try {
if(keystmt != null) keystmt.close();
}
catch (ShunException ex) {
int errorLevel = ex.getErrLevel();
switch (errorLevel) {
case ShunException.SHUN_ERROR:
System.out.println("Error level :SHUN_ERROR");
break;
case ShunException.SHUN_ERROR_CONNECTION_TERMINATED:
System.out.println("Error level :SHUN_ERROR_CONNECTION_TERMINATED");
break;
}
System.out.println("Error message:" + ex.getMessage());
ex.printStackTrace();
}
try {
if(con != null) con.close();
}
catch (ShunException ex) {
int errorLevel = ex.getErrLevel();
switch (errorLevel) {
case ShunException.SHUN_ERROR:
System.out.println("Error level :SHUN_ERROR");
break;
case ShunException.SHUN_ERROR_CONNECTION_TERMINATED:
System.out.println("Error level :SHUN_ERROR_CONNECTION_TERMINATED");
break;
}
System.out.println("Error message:" + ex.getMessage());
ex.printStackTrace();
}
}
}
} |