jdbcfile.java

Jbuilder编写的纱线制衣厂的仓库管理系统（学习java时做的一个系统）源码

package yarn;
import java.sql.*;
/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: </p>
 *
 * @author not attributable
 * @version 1.0
 */
public class JDBCFile {
    Connection conn = null;
    Statement stmt = null;
    //默认构造函数，赋予guest权限
    public JDBCFile()
    {
        String driver = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
        String url = "jdbc:microsoft:sqlserver://sli-wind:1433;DatabaseName=YarnMangerSystem";
        try
        {
            Class.forName(driver);
            conn = DriverManager.getConnection(url,"gu","");
            stmt = conn.createStatement();
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }

    }
    //需要帐号密码访问数据库的构造函数
    public JDBCFile(String user,String pass)
    {
        String driver = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
        String url = "jdbc:microsoft:sqlserver://sli-wind:1433;DatabaseName=YarnMangerSystem";
        try
        {
            Class.forName(driver);
            conn = DriverManager.getConnection(url,user,pass);
            stmt = conn.createStatement();
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }

    }
    //对数据库进行选择操作的默认方法，在类里利用Statement对象进行
    public ResultSet executeQuery(String sql) throws Exception
    {
        ResultSet rs = null;
        try
        {
            rs = stmt.executeQuery(sql);

        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
        return rs;
    }
    //对数据库进行插入和修改操作的默认方法，在类里利用Statement对象进行
    public int insert(String sql) throws Exception
    {
        int insertValue = -1;
        try
        {
            insertValue = stmt.executeUpdate(sql);

        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
        return insertValue;
    }
    //关闭本类的所有连接
    public void close()
    {
        try
        {
            stmt.close();
            conn.close();
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
    }
    //建立一个Statement数据库执行对象并返回
    public Statement getStatement()
    {
        Statement st = null;
        try
        {
            st = conn.createStatement();

        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
        return st;
    }
    //建立一个PrepatedStatement数据库语言执行对象并返回
    public PreparedStatement getPreparedStatement(String SQL)
    {
        PreparedStatement ps = null;
        try
        {
            ps = conn.prepareStatement(SQL);
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
        return ps;
    }
    //设置事务是否自动提交
    public void setCommit(boolean n)
    {
        try
        {
            conn.setAutoCommit(n);
        }
        catch(Exception ex)
        {
            ex.printStackTrace();
        }
    }
    //对事务进行回滚操作
    public void goRollBack()
    {
        try
        {
            conn.rollback();
        }
        catch(Exception ex)
        {
            ex.printStackTrace();
        }
    }
    //确定提交事务
    public void goCommit()
    {
        try
        {
            conn.commit();
        }
        catch(Exception ex)
        {
            ex.printStackTrace();
        }
    }
    public Connection getConnection()
    {
        return this.conn;
    }
}