sqltest2.java

来自「学习java编程的好程序」· Java 代码 · 共 78 行

import java.sql.*;
///通过连接数据库来获取数据
///将setAutoCommit(false)设为falise。即不自动提交。
///rollback进行回滚。
public class sqltest2
{
    private Connection con;
    public static void main(String[] args)
    {
        try
        {
            sqltest2 test=new sqltest2();
            Connection con=test.getConnection();
            con.setAutoCommit(false);
            String sql="select * from teacherinfo";
            String sql1="insert into teacherinfo values('朱雪莲','674322','女','24','1981-1-6','上海市','5000')";
            System.out.println("插入数据后的数据是：");
            test.getStudent1(sql1);
            test.getStudent(con,sql);
            con.rollback();
            System.out.println("回滚数据后的数据是：");
            test.getStudent(con,sql);
        }
        catch(Exception e){}
    }
    public void getStudent1(String sql)
    {
        try
        {
            Statement st=con.createStatement();
            st.executeUpdate(sql);
            st.close();
            con.close();
        }
        catch(Exception e){}
    }
///通过结果集的getstring方法来获得表中的数据字段
///将所有获得来的字段输出。
    public void getStudent(Connection con,String sql)
    {
        try
        {
            Statement st=con.createStatement();
            ResultSet rs=st.executeQuery(sql);
            while(rs.next())
            {
                String name1=rs.getString(1);
                String code1=rs.getString(2);
                String sexy1=rs.getString(3);
                String age1=rs.getString(4);
                System.out.println("\n姓名："+name1+"\t学号："+code1+"\t性别："+sexy1+"\t年龄："+age1);
            }
            st.close();
            con.close();
        }
        catch(Exception e){e.printStackTrace();}
}
///用来连接数据库的类
///con是指定用来连接数据库的连接类
///usrname是进入数据库的用户名
///password 是指进入数据库的密码
///url1是连接数据库的URL
    public Connection getConnection()
    {
        String url1="jdbc:odbc:schoolmanage";
        String username="";
        String password="";
        try
        {
            Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
            con=DriverManager.getConnection(url1,username,password);
        }
        catch(SQLException e){e.printStackTrace();}
        catch(ClassNotFoundException ex){ex.printStackTrace();}
        return con;
    }
}