package com;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
public class NavalMgmtDAO {
public static void main(String[] args) {
NavalMgmtDAO navalMgmtDAO=new NavalMgmtDAO();
double sal=navalMgmtDAO.getOfficersTotalSalOnBaseCamp(38);
System.out.println(sal);
}
public int addNavalOfficer(NavalOfficer navalOfficer)
{
int no=navalOfficer.getOfficerNo();
String name=navalOfficer.getOfficerName();
String rank=navalOfficer.getOfficerRank();
double sal=navalOfficer.getOfficerSal();
int campid=navalOfficer.getBaseCampId();
Connection connection=null;
int status=0;
DBConnectionHelper helper=new DBConnectionHelper();
connection=helper.getOracleConnection();
Statement statement=null;
try {
connection.setAutoCommit(false);
statement=connection.createStatement();
String sql="INSERT INTO TBL_Officer_1273752 values (" +no+",'"+name+"','"+rank+"',"+sal+","+campid+")";
status=statement.executeUpdate(sql);
connection.commit();
} catch (SQLException e) {
//TODO Auto-generated catch block
e.printStackTrace();
}
finally {
try {
if (statement !=null)
statement.close();
//System.out.println(“语句成功关闭”);
}捕捉(SQLException se) {
se.printStackTrace ();
}//什么都不做
尝试{
如果(连接!=null)
connection.close ();
//system . out。println(“连接成功关闭”);
}捕捉(SQLException se) {
se.printStackTrace ();
}//结束最后尝试
}//结束尝试
如果(状态==1){
system . out。println(“数据插入成功”);其他
} {
system . out。println(“连接错误”);}
返回状态;
}
公共int addBaseCamp (BaseCamp BaseCamp)
{
int id=baseCamp.getBaseCampId ();
字符串名称=baseCamp.getBaseCampName ();
int loc=baseCamp.getBaseCampLoc ();
连接连接=零;
int状态=0;
DBConnectionHelper助手=new DBConnectionHelper ();
连接=helper.getOracleConnection ();
语句声明=零;
尝试{
connection.setAutoCommit(假);
声明=connection.createStatement ();
字符串sql=安迦隩BL_Base_Camp_1273752值(“+身份证+”、“+名字+”,“+ loc +”)”,
状态=statement.executeUpdate (sql);
connection.commit ();
}捕捉(SQLException e) {
//TODO自动生成的catch块
e.printStackTrace ();}
最后{
尝试{
如果(声明!=null)
statement.close ();
//system . out。println(“语句成功关闭”);
}捕捉(SQLException se) {
se.printStackTrace ();
}//什么都不做
尝试{
如果(连接!=null)
connection.close ();
//system . out。println(“连接成功关闭”);
}捕捉(SQLException se) {
se.printStackTrace ();
}//结束最后尝试
}//结束尝试
如果(状态==1){
system . out。println(“数据插入成功”);其他
} {
system . out。null
