public class DbUtils {
private final static String URL = "jdbc:oracle:thin:@127.0.0.1:1521:ORCLUJO";
private final static String DRIVER_NAME = "oracle.jdbc.driver.OracleDriver";
private final static String USERNAME = "LUJO";
private final static String PASSWORD = "lujo";
private Connection connection;
private PreparedStatement pstmt;
private ResultSet resultSet;
public DbUtils() {
try {
Class.forName(DRIVER_NAME);
System.out.println("驱动注册成功");
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void connectionToDb() throws SQLException {
connection = DriverManager.getConnection(URL, USERNAME, PASSWORD);
}
public boolean updataByPrepareStatement(String sql, List<Object> params)
throws SQLException {
int result = -1;
int index = 1;
boolean flag = false;
pstmt = connection.prepareStatement(sql);
if (params != null && !params.isEmpty()) {
for (int i = 0; i < params.size(); i++)
pstmt.setObject(index++, params.get(i));
}
result = pstmt.executeUpdate();
flag = result > 0 ? true : false;
return flag;
}
public Map<String, Object> findSimpleResult(String sql, List<Object> params)
throws SQLException {
Map<String, Object> map = new HashMap<String, Object>();
int index = 1;
pstmt = connection.prepareStatement(sql);
if (params != null && !params.isEmpty()) {
for (int i = 0; i < params.size(); i++)
pstmt.setObject(index++, params.get(i));
}
resultSet = pstmt.executeQuery();
ResultSetMetaData rsmd = resultSet.getMetaData();
int col_len = rsmd.getColumnCount();
while (resultSet.next()) {
for (int i = 1; i <= col_len; i++) {
String col_name = rsmd.getColumnName(i);
Object col_value = resultSet.getObject(col_name);
if (col_value == null)
col_value = "";
map.put(col_name, col_value);
}
}
return map;
}
public List<Map<String, Object>> findMoreResult(String sql,
List<Object> params) throws SQLException {
List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();
int index = 1;
pstmt = connection.prepareStatement(sql);
if (params != null && !params.isEmpty()) {
for (int i = 0; i < params.size(); i++)
pstmt.setObject(index++, params.get(i));
}
resultSet = pstmt.executeQuery();
ResultSetMetaData metaData = resultSet.getMetaData();
int col_len = metaData.getColumnCount();
while (resultSet.next()) {
Map<String, Object> map = new HashMap<String, Object>();
for (int i = 1; i <= col_len; i++) {
String col_name = metaData.getColumnName(i);
Object col_value = resultSet.getObject(col_name);
map.put(col_name, col_value);
}
list.add(map);
}
return list;
}
public void colseDb() {
if (resultSet != null) {
try {
resultSet.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if (pstmt != null) {
try {
pstmt.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if (connection != null) {
try {
connection.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
|