怎么用java向数据库中添加和删除数据
发布网友
发布时间：2022-04-26 23:32
共8个回答
热心网友
时间：2022-04-08 02:30
我这有个类，一直用
package com.second.;import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
public class JDBCUtilDao {
private static Connection con = null;
private static PreparedStatement ps = null;
private static ResultSet rs = null;
public static Connection PrintCon() {
return con;
}
public static PreparedStatement PrintPs() {
return ps;
}
public static ResultSet PrintRs() {
return rs;
}
/**
* 准备驱动
*/
static {
try {
Class.forName("net.sourceforge.jtds.jdbc.Driver");
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
System.out.println("加载驱动失败！");
e.printStackTrace();
}
}
public static Connection getConnection() {
try {
con = DriverManager.getConnection(
"jdbc:jtds:sqlserver://192.168.6.110/sql_second", "sa",
"123");
// System.out.println(con);
} catch (SQLException e) {
// TODO Auto-generated catch block
System.out.println("连接失败！");
e.printStackTrace();
}
return con;
}
/**
* 关闭连接
*
* @param rs
* 结果集对象
* @param ps
* 会话对象
* @param con
* 连接对象
*/
public static void closeAll(ResultSet rs, PreparedStatement ps,
Connection con) {
try {
if (null != rs) {
rs.close();
}
if (null != ps) {
ps.close();
}
if (null != con) {
con.close();
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
/**
* 设置参数
*
* @param params
* @param ps
*/
public static void setParams(List<String> params, PreparedStatement ps) {
if (params != null) {
for (int i = 0; i < params.size(); i++) {
try {
ps.setString(i + 1, params.get(i));
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
/**
* 实现增、删、改
*
* @param sql
* sql语句
* @param params
* 参数
* @return 修改的行数
*/
public static int doUpdata(String sql, List<String> params) {
int result = 0;
try {
// 判断是否连接 不连接就把数据库连上
if (null == con || con.isClosed()) {
con = getConnection();
}
// 得到会话
ps = con.prepareStatement(sql);
// 设置参数
setParams(params, ps);
// 得到结果,即改变行数
result = ps.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
closeAll(null, ps, con);
}
return result;
}
/**
* 查询
*
* @param <T>
* @param sql
* @param params
* @param t
* @return
*/
public static <T> List<T> qureyAll(String sql, List<String> params,
Class<T> t) {
// 用一个集合接受返回的数据
List<T> list = new ArrayList<T>();
// 判断是否连接
try {
if (null == con || con.isClosed()) {
con = getConnection();
}
// 操作对象
ps = con.prepareStatement(sql);
// 设置参数
setParams(params, ps);
// 返回结果集
rs = ps.executeQuery();
// 取出t中的说有方法
Method[] method = t.getDeclaredMethods();
// 取出说有列名和列数
ResultSetMetaData rsmd = rs.getMetaData();
// 获得列数
int count = rsmd.getColumnCount();
// 取出每个列列名放入数组中
String[] columns = new String[count];
for (int i = 0; i < columns.length; i++) {
columns[i] = rsmd.getColumnName(i + 1);
}
// 循环结果集
while (rs.next()) {
T s = (T) t.newInstance();
// 第一个循环控制列数
for (int i = 0; i < columns.length; i++) {
// 第二个循环控制方法名
for (int j = 0; j < method.length; j++) {
String setName = "set" + columns[i];
if (setName.equalsIgnoreCase(method[j].getName())) {// set+列名相同就是这个类得方法名
String typeName = rsmd.getColumnTypeName(i + 1);// 得到数据库中列名的类型
// int
// varchar..
//System.out.println(typeName);
if (typeName.equals("INTEGER")
|| typeName.equals("int identity")
|| typeName.equals("int")) {
method[j].invoke(s, rs.getInt(columns[i]));
} else if (typeName.equals("DECIMAL")) {
method[j].invoke(s, rs.getDouble(columns[i]));
} else if (typeName.equals("VARCHAR2")) {
method[j].invoke(s, rs.getString(columns[i]));
} else if (typeName.equals("money")) {
method[j].invoke(s, rs.getFloat(columns[i]));
} else if (typeName.equals("datetime")) {
// System.out.println(rs.getTimestamp(columns[i]));
method[j]
.invoke(s, rs.getTimestamp(columns[i]));
} else {
method[j].invoke(s, rs.getString(columns[i]));
}
}
}
}
list.add(s);
}
closeAll(rs, ps, con);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (InstantiationException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IllegalAccessException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IllegalArgumentException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (InvocationTargetException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return list;
}
/**
* 查询
*
* @param sql
* @param obj
* @return
*/
public static ResultSet getInfoos(String sql, Object[] temp) {
ResultSet rs = null;
try {
if (con == null || con.isClosed()) {
getConnection();
}
ps = con.prepareStatement(sql);
for (int i = 1; i < temp.length; i++) {
ps.setObject(i, temp[i]);
}
rs = ps.executeQuery();
} catch (SQLException e) {
e.printStackTrace();
}
return rs;
}
public static void main(String[] args) {
// JDBCUtilDemo jd = new JDBCUtilDemo();
// System.out.println(jd.getConnection());
// if(jd.updateByUserId("8888" )){
// System.out.println("OK");
// }else{
// System.out.println("NO");
// }
}
}
热心网友
时间：2022-04-08 03:48
热心网友
时间：2022-04-08 05:23
然后把这个jar包拖到Eclipse项目中的lib文件夹下；
接着在src文件夹下新建一个package，然后写一个数据库的类；
关键代码：
String driver = "......";
String url = ".....";
String user= "...";
String password="...";
try{
Class.forName(driver);
Connection conn = DriverManager.getConnection(url);
}catch(Exception e){}
Statement stmt = null;
//查
String sql = "select * from aaa";
stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery(sql);
//增
String sql = "insert into aaa values('a','b','c')";
stmt.execute(sql);
//改
String sql = "update aaa set name='b' where name='a'";
stmt.executeUpdate(sql);
//删
String sql = "delete from aaa where name = 'b'";
stmt.execute(sql);
反正就是类似这样的啦
热心网友
时间：2022-04-08 07:14
热心网友
时间：2022-04-08 09:22
热心网友
时间：2022-04-08 11:47
这个博客够清楚了！可以试着自己弄一弄.大多数都没空，都在上班
热心网友
时间：2022-04-08 14:28
热心网友
时间：2022-04-08 17:26
