JDBC:
1.6大部
1.加载数据库供应商提供的驱动
Class.forName("com.mysql.jdbc.Driver");
2.获取数据库连接对象
Connection conn =DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/test",
"root",
"1234567890");
3.获取处理命令
Statement stmt = conn.createStatement();
4.执行sql命令
boolean f = stmt.execute(add());
5.处理执行结果
System.out.println(f);
6.回收资源
stmt.close();
conn.close();
package oop1;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;
import com.softeem.ooptest.DBConnection;
public class VoteUtils {
public static boolean execUpdate(Connection conn,String sql,Object...objs)
{
try {
PreparedStatement ps = conn.prepareStatement(sql);
for(int i =0;i<objs.length;i++)
{
ps.setObject(i+1,objs[i]);
}
int i =ps.executeUpdate();
return i>0 ? true:false;s
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return false;
}
public static <T>List<T> execQuery(String sql,CallBack<T> call,Object...params)
{
Connection conn =DBConnection.getConn();
PreparedStatement ps = null;
try {
ps =conn.prepareStatement(sql);
for(int i =0;i<params.length;i++){
ps.setObject(i+1, params[i]);
}
ResultSet rs = ps.executeQuery();
return call.getDatas(rs);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return null;
}
public interface CallBack<T>{
public List<T> getDatas(ResultSet rs);
}
}
