java 连接SQL2008(查询、插入、调用存储过程)

时间：2015-04-01 17:40:36 阅读：151 评论：0 收藏：0 [点我收藏+]

标签：

import java.sql.*;
import java.util.*;

public class SQL
{
   private Connection conn;
   private String connStr, sqlStr;
   private String useName, passWord;
   private PreparedStatement ps;
   private ResultSet rs;
//   CallableStatement callProc
   private StringBuffer strBuf = new StringBuffer();

   public Connection getConnection()
   {
       try
       {
           Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver"); // 数据库驱动加载
       } catch (ClassNotFoundException e)
       {
           System.out.println("数据库驱动加载失败！");
       }

       try
       {
           connStr = "jdbc:sqlserver://localhost:1433;DatabaseName=TMP"; // 定义连接数据库URL
           useName = "sa";
           passWord = "";

           conn = DriverManager.getConnection(connStr, useName, passWord); // 连接数据库
           if (conn != null)
               System.out.println("数据库连接OK");
       } catch (Exception e)
       {
           System.out.println("数据库连接失败");
       }

       return conn;
   }

   public void getData() // throws SQLException
   {
       strBuf.delete(0, strBuf.length());
       sqlStr = "select * from TableA";

       try
       {
           if (conn == null || conn.isClosed())
               conn = getConnection();
       } catch (SQLException e1)
       {
           e1.printStackTrace();
       }

       try
       {
           ps = conn.prepareStatement(sqlStr);
           rs = ps.executeQuery();

           while (rs.next())
           {
               // strBuf.append("1").append(rs.getString(1));
               // strBuf.append("1:").append(rs.getString("A"));
               strBuf.append(rs.getString("A")).append("--")
                       .append(rs.getString("B")).append("--")
                       .append(rs.getString("C")).append("--")
                       .append(rs.getString("D"));
               strBuf.append("\r");
           }
           System.out.println(strBuf);
           System.out.println("-----------------------");
       } catch (SQLException e)
       {
           e.printStackTrace();
       } finally
       {
           try
           {
               rs.close();
               ps.close();
               conn.close();
           } catch (SQLException e)
           {
               e.printStackTrace();
           }
       }
   }

   public void insertData() //插入数据，删除、更新同理
   {
       strBuf.delete(0, strBuf.length());
       sqlStr = "insert into TableA(B, C, D) values(?, ?, ?)";

       try
       {
           if (conn == null || conn.isClosed())
               conn = getConnection();
       } catch (SQLException e1)
       {
           e1.printStackTrace();
       }

       try
       {
           ps = conn.prepareStatement(sqlStr);

           ps.setString(1, "B10");
           ps.setDouble(2, 10);
           ps.setString(3, "D10");

           ps.executeUpdate();

           System.out.println("-----------------------");
       } catch (Exception e)
       {
           e.printStackTrace();
       } finally
       {
           try
           {
               rs.close();
               ps.close();
               conn.close();
           } catch (SQLException e)
           {
               e.printStackTrace();
           }
       }
   }

   public void callProc() //调用存储过程，有返回值
   {
       strBuf.delete(0, strBuf.length());
       sqlStr = "";

       try
       {
           if (conn == null || conn.isClosed())
           {
               conn = getConnection();
           }
       } catch (SQLException e)
       {
           e.printStackTrace();
       }

       try
       {
           CallableStatement callProc = conn.prepareCall("{call sp_TableA(?, ?)}");
           callProc.setInt(1, 4);
           callProc.registerOutParameter(2, java.sql.Types.VARCHAR);
           callProc.execute();

           System.out.println(callProc.getString(2));
           System.out.println("-----------------------");
       } catch (SQLException e)
       {
           e.printStackTrace();
       }

   }

   public static void main(String[] args)
   {
       SQL sqlDemo = new SQL();
       // sqlDemo.getConnection();
        sqlDemo.getData();
        sqlDemo.insertData();
       sqlDemo.callProc();
   }

}

标签：

原文地址：http://blog.csdn.net/gjtao1130/article/details/44809387

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)

周排行