//此类为连接数据库并进行数据库的操作
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class Conn {
private static Connection conn = null;
private static Statement st = null;
private static ResultSet rs = null;
//建立数据库的连接
你要连接的是什么数据库
package com.dao.conn;
import com.entity.PubTermBean;
/**
* @author Administrator
*
*/
public static Connection getConn(){
Connection conn=null;
try {
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver").newInstance(); //加载驱动类
} catch (InstantiationException e) {
e.printStackTrace();
} catch (IllegalAccessException e) {
} catch (ClassNotFoundException e) {
} catch (SQLException e) {
}
return conn;
//查询数据库表的方法
public ListUs select() {
Connection con = null;
PreparedStatement pst = null;
ResultSet rt = null;
ListUs list = new ArrayListUs();
String sql="select * from users";//查询语句
pst = con.prepareStatement();
rt = pst.executeQuery();//执行查询
while (rt.next()) { //循环查询的结果集
//将数据封装到javabean里
Us u = new Us();
u.setId(rt.getInt(1));
//将每一个javabean对象放到list集合
list.add(u);
} finally {
//关闭数据库操作对象
if (rt != null) {
rt.close();
if (pst != null) {
pst.close();
if (con != null) {
con.close();
return list; //返回得到的数据库数据
①. import java.sql.Connection;
①.0 * @param args
①.1 */
以上的代码都不如哥的 且看哥是怎么写条理清晰的代码的!!!
package dbconnection //java 中不存在没有包的类(讲解详细因为项目需要)
import java.sql.Statement;//引入sql数据库包
public class DBConnection{
private Connection conn=null;
private Statement stmt=null;
private Result rs=null;
private String jdbc="com.microsoft.sqlserver.jdbc.SQLServerDriver";
private String user="admin";
private int password="admin";
public DBConnection{
try{
Class.forName("jdbc");
conn.getConnection("driverManager");
catch(Exception e){}
public selectMethod(String sql){
stmt=conn.createStatement();
rs=stmt.extcuteQuery("sql");
while(rs.next()){
String title=rs.getString("title");//利用javaBean获得数据库中的属性
String name=rs.getString("name");
.......
System.out.println("title");
System.out.println("name");
......
//当然数据库的操作有很多 这里简单介绍下功能的实现
public void closeDB(){
if(rs != null) rs.close();
if(stmt != null) stmt.close();
if(conn != null) conn.close();
用这个类吧.好的话,给我加加分.
import java.sql.*;
* @功能: 一个JDBC的本地化API连接类,封装了数据操作方法,只用传一个SQL语句即可
public class ConnectionDemo {
/*
* 这里可以将常量全部放入另一个类中,以方便修改
private static Connection conn;
private static Statement ps;
private static ResultSet rs;
private static final String DRIVER = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
private static final String USER ="sa";
private static final String PASS = "sa";
public ConnectionDemo() {
// TODO Auto-generated constructor stub
ConnectionDemo.getConnection();
public static Connection getConnection(){
System.out.println("连接中...");
Class.forName(ConnectionDemo.DRIVER);
conn = DriverManager.getConnection(ConnectionDemo.URL, ConnectionDemo.USER, ConnectionDemo.PASS);
System.out.println("成功连接");
// TODO Auto-generated catch block
public static Statement getStatement(String sql){
System.out.println("执行SQL语句中...");
ps = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
rs = ps.executeQuery(sql);
System.out.println("执行完查询操作,结果已返回ResultSet集合");
ps.executeUpdate(sql);
System.out.println("已执行完毕删除操作");
System.out.println("已执行完毕增加操作");
}else{
System.out.println("已执行完毕更新操作");
return ps;
public static ResultSet getResultSet(){
System.out.println("查询结果为:");
return rs;
public static void closeConnection(){
System.out.println("关闭连接中...");
if (rs != null) {
rs.close();
System.out.println("已关闭ResultSet");
if (ps != null) {
ps.close();
System.out.println("已关闭Statement");
if (conn != null) {
conn.close();
System.out.println("已关闭Connection");
} catch (Exception e) {
// TODO: handle exception
public static void main(String[] args) {
// TODO Auto-generated method stub
String sql = "delete from type where id = 1";
ConnectionDemo.getStatement(sql);
String sql1 = "select * from type";
ConnectionDemo.getStatement(sql1);
ResultSet rs = ConnectionDemo.getResultSet();
System.out.println("编号 "+"类 型");
System.out.print(" "+rs.getInt(1)+" ");
ConnectionDemo.closeConnection();