sqlContext.read().jdbc(DB_URL, "tb_log", getDBProperties()).select("financeStage")

时间: 2023-06-10 19:02:40 浏览: 124

JDBC访问数据库的步骤

3星 · 编辑精心推荐

JDBC访问数据库的步骤 1. 新建java项目：JDBC，新建 class文件：TestJDBC 2. JDBC用到的类库基本都位于java.sql.*包中，程序中引入该包： Import java.sql.*; 3. 添加要用的数据库中的包，找到数据库中的Driver.class文件：项目名上点右键，Build Path—Add External Archives… 构建路径----添加外部归档加入mysql-connector-java-5.1.12 4. 从包中找到要用的驱动，展开包，从中找到Driver.class，编程时，先把这个类的驱动new一个实例对象出来，告诉DriverManage，要连到哪种数据库上：方法一：Class.forName(“com.mysql.jdbc.Driver”); Class: java.lang中的特殊类，类的装载器； forName：会抛异常； com.mysql.jdbc.Driver中的Driver会new一个它的实例对象方法二：new com.mysql.jdbc.Driver(); new出来后会自动向DriverManage注册。 5. 得到数据库的连接： Connection conn=DriverManager.getConnection (数据库的连接串，用户名，密码)；数据库的连接串：“jdbc:mysql://localhost:3306/books” 用户名： “root” 密码： “111” 程序调试： import java.sql.*; public class TestJDBC { public static void main(String[] args)throws Exception { Class.forName("com.mysql.jdbc.Driver"); Connection conn=DriverManager.getConnection ("jdbc:mysql://localhost:3306/books?","root","111"); System.out.println("Connection Successful!"); } } * *对数据库表的操作通常有：executeQuery() executeUpdate() 6. （1）应用Statement接口获取Statement对象，通过Statement对象执行SQL语句： Statement stmt=con.createStatement(); 执行SQL查询，返回给结果集对象： ResultSet rs=stmt. executeQuery(“select * from 表名”)；或表名”+条件）；遍历访问数据表：while(rs.next()) 以各种类型显示输出：rs.get×××(“字段名”) （2）应用PreparedStatement接口 (p203) 执行数据更新executeUpdate()：insert、update、delete SQL语句的创建：String sql=“sql命令”；创建PreparedStatement的对象： pstmt=con. PrepareStatement(sql); 执行赋值操作（“？”占位符的用法）：执行：insert、update、delete result=pstmt. executeUpdate(); result类型为整型，返回一个整数，小于零操作没成功 7．关闭不再使用的如：rs.close(); stmt.close(); con.close(); JDBC编程步骤总结： 1． Load the Driver:Class.forName(); 2． Connect the DateBase: DriveManager.getConnection() 3． Execute the SQL: (1) Connection.createStatement() Connection.prepareStatement(sql) （2）Statement.executeQuery() （3）Statement.executeUpdate() 4. Retrieve the result data: 循环取得结果while(rs.next()) 5. Show the result data:将遍历的结果记录显示出来 6．Close:结束时关闭 //完善的JDBC程序 import java.sql.*; public class TestJDBC { public static void main(String[] args) { Connection conn=null; Statement stmt=null; ResultSet rs=null; try{ Class.forName("com.mysql.jdbc.Driver"); conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/books?","root","111"); System.out.println("Connection Successful!"); stmt=conn.createStatement(); rs=stmt.executeQuery("select * from titles"); while (rs.next()){ System.out.println(rs.getString("isbn")+" "+rs.getString("title")); } }catch(ClassNotFoundException e){ e.printStackTrace(); }catch(SQLException e){ e.printStackTrace(); }finally{ try{ if(rs!=null){ rs.close（）; rs=null; } if(stmt!=null){ stmt.close（）; stmt=null; } if(con!=null){ con.close（）; con=null; } }catch(SQLException e){ e.printStackTrace(); } } } JDBC（Java Database Connectivity）是Java语言中用来规范客户端程序如何访问数据库的应用程序接口，提供了诸如查询和更新数据库中数据的方法。以下是对JDBC访问数据库的详细步骤的解析： 1. **导入JDBC库**：在Java项目中，首先需要引入JDBC相关的类库，这些类通常位于`java.sql.*`包中。在Java源代码中，添加`import java.sql.*;`语句以引入所有必需的JDBC接口和类。 2. **加载数据库驱动**：要与特定的数据库进行交互，必须先加载相应的数据库驱动。这可以通过调用`Class.forName()`方法完成，例如`Class.forName("com.mysql.jdbc.Driver")`。这个方法会根据指定的全限定类名加载并初始化类，对于MySQL，是`com.mysql.jdbc.Driver`。另一种方式是直接实例化驱动类，如`new com.mysql.jdbc.Driver()`，这会导致驱动自动注册到`DriverManager`。 3. **建立数据库连接**：使用`DriverManager.getConnection()`方法创建数据库连接。需要提供连接字符串（包括数据库URL、数据库名称、端口号等）、用户名和密码。例如： ```java Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/books", "root", "111"); ``` 4. **执行SQL语句**： JDBC提供了两种主要的方式来执行SQL语句：`Statement`接口和`PreparedStatement`接口。 - **Statement接口**：适用于执行静态SQL查询和更新。创建Statement对象，然后调用`executeQuery()`或`executeUpdate()`方法。例如： ```java Statement stmt = conn.createStatement(); ResultSet rs = stmt.executeQuery("SELECT * FROM table_name"); ``` 遍历结果集`ResultSet`，获取数据并处理。 - **PreparedStatement接口**：用于预编译SQL语句，提高效率并防止SQL注入。创建PreparedStatement对象，通过占位符`?`来设置参数，然后执行`executeQuery()`或`executeUpdate()`。例如： ```java String sql = "INSERT INTO table_name VALUES (?, ?)"; PreparedStatement pstmt = conn.prepareStatement(sql); pstmt.setString(1, value1); pstmt.setInt(2, value2); pstmt.executeUpdate(); ``` 5. **处理结果**：如果是查询语句，使用`ResultSet`对象遍历结果，调用`next()`方法移动指针并使用`getXXX()`方法获取字段值。例如： ```java while (rs.next()) { System.out.println(rs.getString("column1") + " " + rs.getInt("column2")); } ``` 6. **关闭资源**：操作完成后，务必关闭不再使用的资源，包括`ResultSet`、`Statement`和`Connection`对象，以释放系统资源。通常使用`try-catch-finally`结构确保关闭操作始终执行。例如： ```java finally { try { if (rs != null) { rs.close(); rs = null; } if (stmt != null) { stmt.close(); stmt = null; } if (conn != null) { conn.close(); conn = null; } } catch (SQLException e) { e.printStackTrace(); } } ``` 总结JDBC编程步骤： 1. 加载驱动：`Class.forName()`。 2. 连接数据库：`DriverManager.getConnection()`。 3. 执行SQL： - `Connection.createStatement()`创建Statement执行查询/更新。 - `Connection.prepareStatement(sql)`创建PreparedStatement预编译SQL。 4. 获取结果：循环`ResultSet`获取数据。 5. 显示结果：处理并显示遍历的结果。 6. 关闭资源：关闭`ResultSet`、`Statement`和`Connection`。以上就是使用JDBC访问数据库的基本步骤，这适用于大多数关系型数据库，如MySQL、Oracle、SQL Server等。在实际开发中，为了更高效和安全，通常会使用ORM框架，如Hibernate或MyBatis，它们提供了更高级的抽象和自动化处理。

这是一个关于读取数据库中表 tb_log 中 financeStage 列的 SQL 查询语句。该语句使用了 Spark SQL 中的 JDBC 数据源来从 DB_URL 所指定的数据库中读取数据，并通过 getDBProperties() 函数来获取数据库连接属性。read()、jdbc() 和 select() 都是 Spark SQL 中的 API，用于读取和查询数据。

阅读全文

sqlContext.read().jdbc(DB_URL, "tb_log", getDBProperties()).select("financeStage")

相关推荐

JDBC访问数据库步骤

JDBC 访问数据的步骤

sqlContext.read().jdbc(DB_URL, "tb_log", getDBProperties()).select("financeStage", "count(*)").groupBy("financeStage");

sqlContext.read().jdbc(DB_URL, "lagou_data", getDBProperties());解释这段代码

sqlContext.read().jdbc(DB_URL, "lagou_data", getDBProperties())怎么执行sql代码，返回结果

public Integer countLog(String type) { DataFrame rows = sqlContext.read().jdbc(DB_URL, "tb_log", getDBProperties()). where("opt ='" + type + "'"); JavaRDD<Row> testRdd= rows.toJavaRDD(); return testRdd.collect().size(); }解释一下这段代码

sqlContext.read().jdbc()执行带条件的sql语句

DataFrame lagou_data = sqlContext .sql("select financeStage as name,count(*) as value from lagou_data group by financeStage order by count(*) desc limit 10");这段代码有问题吗

sqlContext.sql('SELECT是什么

df.sqlContext().sql("select financeStage as name,count(*) as value from tb_log group by financeStage order by count(*) desc limit 10");解释一下这段代码

ListView上下翻页效果.zip

Android项目之——漂亮的平台书架.zip

TestBrightness2.zip

00_Método_toBands.ipynb

(源码)基于Linux和GTK的系统监控与图形化显示.zip

最新推荐

ListView上下翻页效果.zip

Android项目之——漂亮的平台书架.zip

TestBrightness2.zip

00_Método_toBands.ipynb

(源码)基于Linux和GTK的系统监控与图形化显示.zip

Java集合ArrayList实现字符串管理及效果展示

管理建模和仿真的文件

【MATLAB信号处理优化】：算法实现与问题解决的实战指南

在西门子S120驱动系统中，更换SMI20编码器时应如何确保数据的正确备份和配置？

实现2D3D相机拾取射线的关键技术

DataFrame lagou_data = sqlContext .sql("select financeStage as name,count() as value from lagou_data group by financeStage order by count() desc limit 10");这段代码有问题吗

df.sqlContext().sql("select financeStage as name,count() as value from tb_log group by financeStage order by count() desc limit 10");解释一下这段代码