Java如何获取数据库中的数据·案例

下面是一个从 mysql 数据获取用户数据的案例，可以参考一下：

import java.sql.Connection

import java.sql.DriverManager

import java.sql.ResultSet

import java.sql.SQLException

import java.sql.Statement

import java.util.ArrayList

import java.util.List

// 用户类，存储单个用户信息

class User {

private int id

private String name

public User(int id, String name) {

this.id = id

this.name = name

}

public int getId() {

return id

}

public void setId(int id) {

this.id = id

}

public String getName() {

return name

}

public void setName(String name) {

this.name = name

}

@Override

public String toString() {

return "User [id=" + id + ", name=" + name + "]"

}

}

public class Demo1 {

public static void main(String[] args) throws ClassNotFoundException, SQLException {

// 本例使用 mysql 数据库，演示将数据库 test 的 tb_users 表中的用户信息

// 放到 List 中

// 加载数据驱动

Class.forName("com.mysql.jdbc.Driver")

// 数据库连接字符串, 此例数据库为 test

String url = "jdbc:mysql://localhost:3306/test"

String user = "root" // 数据库用户名

String password = "" // 数据库密码

// 打开一个数据连接

Connection conn = DriverManager.getConnection(url, user, password)

Statement stmt = conn.createStatement()

// 获取表 tb_users 所有用户信息到结果集中

ResultSet rs = stmt.executeQuery("SELECT id, name FROM tb_users")

// 定义一个存放用户信息的 List

List<User> users = new ArrayList<>()

// 提取用户信息，并将用户信息放入 List

while (rs.next()) {

// 获取用户ID

int id = rs.getInt(1)

// 获取用户名

String name = rs.getString(2)

users.add(new User(id, name))

}

rs.close()

stmt.close()

conn.close()

// 显示用户信息

for (User u : users) {

System.out.println(u)

}

}

}

//将数据库中的数据条数分段

public void division(){

//获取要导入的总的数据条数

String sql3="SELECT count(*) FROM [CMD].[dbo].[mycopy1]"

try {

pss=cons.prepareStatement(sql3)

rss=pss.executeQuery()

while(rss.next()){

System.out.println("总记录条数:"+rss.getInt(1))

sum=rss.getInt(1)

}

//每30000条记录作为一个分割点

if(sum>=30000){

n=sum/30000

residue=sum%30000

}else{

用JDBC连接数据库，然后用sql语句。要导入mysql的驱动包。

import java.sql.*

public class TestMySql {

static Connection con = null// 声明Connection对象

static Statement sql = null

static ResultSet res = null

public static void main(String[] args) {

TestMySql c = new TestMySql()

con = c.getConnection()

try {

sql = con.createStatement()

res = sql.executeQuery("select * from dept")

//sql语句，我数据库里有张dept表

while (res.next()) {//输出结果

System.out.print(res.getString(1) + "<——>")

System.out.print(res.getString(2) + "<——>")

System.out.print(res.getString(3) )

System.out.println()

}

} catch (SQLException e) {

e.printStackTrace()

} finally {

try {

if (res != null) {

res.close()

res =null

}

if (sql != null) {

sql.close()

sql =null

}

if (con != null) {

con.close()

con =null

}

} catch (SQLException e) {

e.printStackTrace()

}

}

}

public Connection getConnection() {

try {

Class.forName("com.mysql.jdbc.Driver")

// 加载oracleJDBC驱动

System.out.println("数据库驱动加载成功")

} catch (ClassNotFoundException e) {

e.printStackTrace()

}

try {// 通过访问数据库的URL获取数据库连接对象

con = DriverManager.getConnection(

"jdbc:mysql://localhost:3306/mydata", "root", "qwer1234")

//mydata为mysql名字

System.out.println("数据库连接成功")

} catch (SQLException e) {

e.printStackTrace()

}

return con// 按方法要求返回一个Connection对象

}

}

---