如何在Java程序中访问mysql数据库中的数据并进行简单的 *** 作

/ 

      获取数据库的连接 

      @return conn 

     /  

    public static  Connection getConnection() throws Exception{  

      String url = "jdbc:mysql://101035188:3306/sgjwx";  

      String user = "opermain";  

      String psw = "opermain";  

      Connection conn = null;

      PreparedStatement pstm = null;

      ResultSet rs = null;

     ClassforName("commysqljdbcDriver");  

        if(null == conn) {  

            try {  

                conn = DriverManagergetConnection(url, user, psw);  

            } catch (SQLException e) {  

                Systemoutprintln("获取失败");

                throw new RuntimeException(e);  

            } finally{

             closeResources(conn,pstm,rs);

            } 

        }  

        return conn;  

    }  

    / 

      释放资源 

      @param conn 

      @param pstmt 

      @param rs 

     /  

    public  static void closeResources(Connection conn,PreparedStatement pstmt,ResultSet rs) {  

        if(null != rs) {  

            try {  

                rsclose();  

            } catch (SQLException e) {  

                eprintStackTrace();  

                throw new RuntimeException(e);  

            } finally {  

                if(null != pstmt) {  

                    try {  

                        pstmtclose();  

                    } catch (SQLException e) {  

                        eprintStackTrace();  

                        throw new RuntimeException(e);  

                    } finally {  

                        if(null != conn) {  

                            try {  

                                connclose();  

                            } catch (SQLException e) {  

                                eprintStackTrace();  

                                throw new RuntimeException(e);  

                            }  

                        }  

                    }  

                }  

            }  

        }  

    } 

    //       //tuserrole执行插入

//         try {

//          String sql = "insert into sys_userrole(roleid,userid) values (,)";

//             conn = getConnection();  

//             connsetAutoCommit(false);  

//             PreparedStatement pstmt = (PreparedStatement) connprepareStatement(sql,StatementRETURN_GENERATED_KEYS);//传入参数：StatementRETURN_GENERATED_KEYS

//             pstmtsetInt(1, 5);

//             pstmtsetInt(2, sid);

//             pstmtexecuteUpdate();

//             ResultSet rs = pstmtgetGeneratedKeys(); //获取结果   

//             int a = -1;

//          if (rsnext()) {

//          a = rsgetInt(1);//取得ID

//          }

//          Systemoutprintln(a);

//             Systemoutprintln("t_userrole执行成功");

//             conncommit(); 

//         } catch (Exception e) {  

//          eprintStackTrace();

//          Systemoutprintln("执行失败");

//         }

很简单的题目，具体代码如下，数据库驱动，用户名，密码，你要自己改，我用的oracle

import javasqlConnection;

import javasqlDriverManager;

import javasqlPreparedStatement;

import javasqlResultSet;

public class MySelect {

private static String database_name = "oraclejdbcdriverOracleDriver";

private static String database_url = "jdbc:oracle:thin:@localhost:1521:oral";

private static String database_username = "store";

private static String database_password = "store";

private static String sql = "select aname,bsubject,byear,bmonth,"

+ "bscore from table_b b,(select name,subject from table_a)

a"

+ " where bsubject <> asubject";

static Object[][] getResult(String sql) {

Object[][] result = new Object[10][5];

try {

ClassforName(database_username);

Connection conn = DriverManagergetConnection(database_url,

database_name, database_password);

PreparedStatement ps = connprepareStatement(sql);

ResultSet rs = psexecuteQuery();

int j = 0;

while (rsnext()) {

for (int i = 0; i < result[i]length; i++) {

result[j][i] = rsgetObject(i + 1);

}

j++;

}

} catch (Exception e) {

}

return result;

}

public static void main(String[] args) {

// 测试

Object[][] o = getResult(sql);

}

}

ClassforName("commicrosoftsqlserverjdbcSQLServerDriver");//加载数据库驱动

String url = "jdbc:sqlserver://127001:1433;databaseName=testDB";//IP:端口;databaseName:数据库名

String sql = "select name from t_user";//sql 查询语句

Connection con = DriverManagergetConnection(url , username , password );//url:

数据库连接串   userName:数据库登录账号   passWord：数据库登录密码

Statement stmt = concreateStatement(ResultSetTYPE_SCROLL_SENSITIVE,ResultSetCONCUR_READ_ONLY);

ResultSet rs = stmtexecuteQuery(sql);

while(rsnext()){

    Systemoutprintln(rsgetString("name"));

}

jdbc的驱动jar包与你用的的数据库有关，如果你是oracle就去网上搜一个oracle的驱动jar，如果是mysql就搜一个mysql的驱动jar，如果你是oracle的话，安装目录了里会有jar包，oracle\product\1020\db_1\jdbc\lib，好像是这里面有好一个，我记得我用的是ojdbc14，或者ojdbc14 -G 记不清了因为好久没用了

1、加载驱动程序。

2、创建连接对象。

3、创建sql语句执行对象 。

4、执行sql语句。

5、对执行结果进行处理。

6、关闭相关的连接对象即可（顺序跟声明的顺序相反）。

处理结果两种情况:

1、执行更新返回的是本次 *** 作影响到的记录数。

2、执行查询返回的结果是一个ResultSet对象。

ResultSet包含符合SQL语句中条件的所有行，并且它通过一套get方法提供了对这些 行中数据的访问。

扩展资料：

Statement

要执行SQL语句，必须获得javasqlStatement实例，Statement实例分为以下3 种类型:

1、执行静态SQL语句。通常通过Statement实例实现。

2、执行动态SQL语句。通常通过PreparedStatement实例实现。

3、执行数据库存储过程。通常通过CallableStatement实例实现。

参考资料：

createStatement 这个不是报错，只是这句可能会抛出异常，这种情况在java中是必须使用 try catch 捕捉的。 你只要把代码块用 try catch 包起来就可以了。

以上就是关于如何在Java程序中访问mysql数据库中的数据并进行简单的 *** 作全部的内容，包括:如何在Java程序中访问mysql数据库中的数据并进行简单的 *** 作、数组数据匹配、如何用java 连接 sqlserver 数据库等相关内容解答，如果想了解更多相关内容，可以关注我们，你们的支持是我们更新的动力！