檬味博客 » 问答 » java如何实现sql连接和查询的代码？

java如何实现sql连接和查询的代码？

//创建数据库连接对象private Connection con=null;//创建数据库预编译对象private PreparedStatement ps=null;//创建结果集private ResultSet rs=null;//创建数据源对象public static DataSource source=null;// //静态代码块 // static{ // // //初始化配置文件context // try { ...
java如何实现sql连接和查询的代码？
import java.sql.Connection。
import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;import javax.naming.Context; import javax.naming.InitialContext; import javax.naming.NamingException; import javax.sql.DataSource;public class DBCon {//数据库驱动对象public static final String DRIVER="oracle.jdbc.driver.OracleDriver";//数据库连接地址(数据库名)public static final String URL="jdbc:oracle:thin:@localhost:1521:orcl";//登陆名public static final String USER="FM";//登陆密码public static final String PWD="FM";//创建数据库连接对象private Connection con=null;//创建数据库预编译对象private PreparedStatement ps=null;//创建结果集private ResultSet rs=null;//创建数据源对象public static DataSource source=null;// //静态代码块 // static{ // // //初始化配置文件context // try { // Context context=new InitialContext(); // source=(DataSource)context.lookup("java:comp/env/jdbc/webmessage"); // } catch (Exception e) { // // TODO Auto-generated catch block // e.printStackTrace(); // } // // // }/*** 获取数据库连接*/public Connection getCon(){try {Class.forName(DRIVER);} catch (ClassNotFoundException e) {// TODO Auto-generated catch blocke.printStackTrace();}try {con=DriverManager.getConnection(URL,USER,PWD);} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}return con;} // /** // * 获取数据库连接 // */ // public Connection getCon(){ // // try { // con=source.getConnection(); // } catch (SQLException e) { // // TODO Auto-generated catch block // e.printStackTrace(); // } // // return con; // } /*** 关闭所有资源*/public void closeAll(){if(rs!=null)try {rs.close();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}if(ps!=null)try {ps.close();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}if(con!=null)try {con.close();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();} }/*** @param sql数据库更新(增、删、改) 语句* @param pras参数列表（可传，可不传，不传为NULL，以数组形式存在）* @return 返回受影响都行数*/public int update(String sql,String... pras){int resu=0;con=getCon();try {ps=con.prepareStatement(sql);for(int i=0;i<pras.length;i++){ps.setString(i+1,pras[i]);}resu=ps.executeUpdate();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}finally{closeAll();}return resu;}/*** @param sql数据库查询语句* @param pras参数列表（可传，可不传，不传为NULL，以数组形式存在）* @return 返回结果集*/public ResultSet query(String sql,String... pras){con=getCon();try {ps=con.prepareStatement(sql);if(pras!=null)for(int i=0;i<pras.length;i++){ps.setString(i+1, pras[i]);}rs=ps.executeQuery();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}return rs;} }
2018-03-16
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.sql.DataSource;

public class DBCon {
//数据库驱动对象
public static final String DRIVER="oracle.jdbc.driver.OracleDriver";
//数据库连接地址(数据库名)
public static final String URL="jdbc:oracle:thin:@localhost:1521:orcl";
//登陆名
public static final String USER="FM";
//登陆密码
public static final String PWD="FM";
//创建数据库连接对象
private Connection con=null;
//创建数据库预编译对象
private PreparedStatement ps=null;
//创建结果集
private ResultSet rs=null;
//创建数据源对象
public static DataSource source=null;

// //静态代码块
// static{
//
// //初始化配置文件context
// try {
// Context context=new InitialContext();
// source=(DataSource)context.lookup("java:comp/env/jdbc/webmessage");
// } catch (Exception e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// }
//
//
// }

/**
* 获取数据库连接
*/
public Connection getCon(){
try {
Class.forName(DRIVER);
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
try {
con=DriverManager.getConnection(URL,USER,PWD);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

return con;
}
// /**
// * 获取数据库连接
// */
// public Connection getCon(){
//
// try {
// con=source.getConnection();
// } catch (SQLException e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// }
//
// return con;
// }

/**
* 关闭所有资源
*/
public void closeAll(){
if(rs!=null)
try {
rs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
if(ps!=null)
try {
ps.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
if(con!=null)
try {
con.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

}
/**
* @param sql数据库更新(增、删、改) 语句
* @param pras参数列表（可传，可不传，不传为NULL，以数组形式存在）
* @return 返回受影响都行数
*/
public int update(String sql,String... pras){
int resu=0;
con=getCon();
try {
ps=con.prepareStatement(sql);
for(int i=0;i<pras.length;i++){
ps.setString(i+1,pras[i]);
}
resu=ps.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally{
closeAll();
}
return resu;
}

/**
* @param sql数据库查询语句
* @param pras参数列表（可传，可不传，不传为NULL，以数组形式存在）
* @return 返回结果集
*/
public ResultSet query(String sql,String... pras){
con=getCon();
try {
ps=con.prepareStatement(sql);

if(pras!=null)
for(int i=0;i<pras.length;i++){
ps.setString(i+1, pras[i]);
}
rs=ps.executeQuery();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return rs;
}

}2018-01-07
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.sql.DataSource;

public class DBCon {
//数据库驱动对象
public static final String DRIVER="oracle.jdbc.driver.OracleDriver";
//数据库连接地址(数据库名)
public static final String URL="jdbc:oracle:thin:@localhost:1521:orcl";
//登陆名
public static final String USER="FM";
//登陆密码
public static final String PWD="FM";
//创建数据库连接对象
private Connection con=null;
//创建数据库预编译对象
private PreparedStatement ps=null;
//创建结果集
private ResultSet rs=null;
//创建数据源对象
public static DataSource source=null;

// //静态代码块
// static{
//
// //初始化配置文件context
// try {
// Context context=new InitialContext();
// source=(DataSource)context.lookup("java:comp/env/jdbc/webmessage");
// } catch (Exception e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// }
//
//
// }

/**
* 获取数据库连接
*/
public Connection getCon(){
try {
Class.forName(DRIVER);
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
try {
con=DriverManager.getConnection(URL,USER,PWD);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

return con;
}
// /**
// * 获取数据库连接
// */
// public Connection getCon(){
//
// try {
// con=source.getConnection();
// } catch (SQLException e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// }
//
// return con;
// }

/**
* 关闭所有资源
*/
public void closeAll(){
if(rs!=null)
try {
rs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
if(ps!=null)
try {
ps.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
if(con!=null)
try {
con.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

}
/**
* @param sql数据库更新(增、删、改) 语句
* @param pras参数列表（可传，可不传，不传为NULL，以数组形式存在）
* @return 返回受影响都行数
*/
public int update(String sql,String... pras){
int resu=0;
con=getCon();
try {
ps=con.prepareStatement(sql);
for(int i=0;i<pras.length;i++){
ps.setString(i+1,pras[i]);
}
resu=ps.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally{
closeAll();
}
return resu;
}

/**
* @param sql数据库查询语句
* @param pras参数列表（可传，可不传，不传为NULL，以数组形式存在）
* @return 返回结果集
*/
public ResultSet query(String sql,String... pras){
con=getCon();
try {
ps=con.prepareStatement(sql);

if(pras!=null)
for(int i=0;i<pras.length;i++){
ps.setString(i+1, pras[i]);
}
rs=ps.executeQuery();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return rs;
}

}2018-03-15
mengvlog 阅读 7 次 更新于 2025-07-20 16:54:45 我来答关注问题0
3 个回答檬味博客专题活动
  • 文暄生活科普 如何在Java和SQL之间使用JPAStreamer进行LINQ查询

    尽管Java流式API与SQL在某些方面具有相似性，但它们并未直接等同于C#的LINQ。然而，通过引入JPAStreamer这一开源库，Java开发者可以将流式API的优势与数据库查询结合起来。JPAStreamer充当了一个桥梁，它将Java流式API与数据库查询连接起来，使得开发者能够以类似LINQ的方式编写高效的数据库查询。为了实现这...

  • 湖北倍领科技 java对pl sql数据库查询,增加,修改,删除操作

    首先，需要导入相关包：import java.sql.*;然后定义一个JDBCTest类，并在其中编写main方法：public class JDBCTest { public static void main(String[] args) { 接下来定义数据库连接的驱动程序名、URL、用户名和密码：String driver = "com.mysql.jdbc.Driver"; String url = "jdbc:mysql://127...

  • 鹰的飞翔sunjun java如何实现sql连接和查询的代码?

    import java.sql.Connection。import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;import javax.naming.Context; import javax.naming.InitialContext; import javax.naming.NamingException; import javax.sql.DataSource;public ...

  • 文暄生活科普 如何通过java连接到sqlserver数据库中?

    1.1 查看JDK版本：通过在命令提示符中输入"java --version"来确认JDK版本。1.2 下载驱动：访问SQL Server官网，下载适用于当前JDK版本的SQL Server JDBC驱动，解压后将其存放到易于访问的目录。1.3 加载驱动类：在Java程序中引入SQL Server的JDBC驱动类，以便后续的数据库连接。2.1 连接数据库：在Ja...

  • 翡希信息咨询 java通过jdbc如何连接到SQL server 2008

    Java通过JDBC连接到SQL Server 2008的步骤如下：下载并安装SQL Server JDBC Driver：到微软官方网站搜索并下载适用于SQL Server 2008的JDBC Driver，确保版本正确，否则可能会导致连接失败。设置SQL Server的固定端口：由于SQL Server 2008采用了可变端口，为了稳定连接，需要打开SQL Server 配置管理器。在SQL ...

其他CSS类似问题

檬味博客在线解答立即免费咨询

CSS相关话题

Copyright © 2023 WWW.MENGVLOG.COM - 檬味博客
返回顶部