package demo1;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class DbConn {
// 创建静态全局变量
static Connection conn;
static Statement st;
public static void main(String[] args) {
insert(); //插入添加记录
query();
}
/* 插入数据记录,并输出插入的数据记录数*/
public static void insert() {
cOnn= getConnection1(); // 首先要获取连接,即连接到数据库
try {
String sql = "INSERT INTO emp(user_id,user_name,user_salary)"
+ " VALUES ('4', 'big','7777')"; // 插入数据的sql语句
st = (Statement) conn.createStatement(); // 创建用于执行静态sql语句的Statement对象//Statement st=?
int count = st.executeUpdate(sql); // 执行插入操作的sql语句,并返回插入数据的个数
System.out.println("向staff表中插入 " + count + " 条数据"); //输出插入操作的处理结果
conn.close(); //关闭数据库连接
} catch (SQLException e) {
System.out.println("插入数据失败" + e.getMessage());
}
}
/* 更新符合要求的记录,并返回更新的记录数目*/
/* 获取数据库连接的函数*/
public static Connection getConnection1() {
Connection con = null; //创建用于连接数据库的Connection对象
try {
Class.forName("com.mysql.jdbc.Driver");// 加载Mysql数据驱动
con = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/myuser","root", "1");// 创建数据连接
} catch (Exception e) {
System.out.println("数据库连接失败" + e.getMessage());
}
return con; //返回所建立的数据库连接
}
public static void query() {
cOnn= getConnection1(); //同样先要获取连接,即连接到数据库
try {
String sql = "select * from emp"; // 查询数据的sql语句
st = (Statement) conn.createStatement(); //创建用于执行静态sql语句的Statement对象,st属局部变量
ResultSet rs = st.executeQuery(sql); //执行sql查询语句,返回查询数据的结果集
System.out.println("最后的查询结果为:");
while (rs.next()) { // 判断是否还有下一个数据
// 根据字段名获取相应的值
String name = rs.getString("user_name");
int name_id = rs.getInt("name_id");
String user_salary = rs.getString("user_salary");
//输出查到的记录的各个字段的值
System.out.println(name + " " + name_id + " " +user_salary+ " ");
}
conn.close(); //关闭数据库连接z
} catch (SQLException e) {
System.out.println("查询数据失败");
}
}
}
代码很简单 一个 insert() 一个query()
插入一条数据之后 然后再查询一下,发现怎么都不显示结果 ,有没有大神帮忙看看什么问题。。
好想是rs这个对象一直没有获取到值。。。。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class DbConn {
// 创建静态全局变量
static Connection conn;
static Statement st;
public static void main(String[] args) {
insert(); //插入添加记录
query();
}
/* 插入数据记录,并输出插入的数据记录数*/
public static void insert() {
cOnn= getConnection1(); // 首先要获取连接,即连接到数据库
try {
String sql = "INSERT INTO emp(user_id,user_name,user_salary)"
+ " VALUES ('4', 'big','7777')"; // 插入数据的sql语句
st = (Statement) conn.createStatement(); // 创建用于执行静态sql语句的Statement对象//Statement st=?
int count = st.executeUpdate(sql); // 执行插入操作的sql语句,并返回插入数据的个数
System.out.println("向staff表中插入 " + count + " 条数据"); //输出插入操作的处理结果
conn.close(); //关闭数据库连接
} catch (SQLException e) {
System.out.println("插入数据失败" + e.getMessage());
}
}
/* 更新符合要求的记录,并返回更新的记录数目*/
/* 获取数据库连接的函数*/
public static Connection getConnection1() {
Connection con = null; //创建用于连接数据库的Connection对象
try {
Class.forName("com.mysql.jdbc.Driver");// 加载Mysql数据驱动
con = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/myuser","root", "1");// 创建数据连接
} catch (Exception e) {
System.out.println("数据库连接失败" + e.getMessage());
}
return con; //返回所建立的数据库连接
}
public static void query() {
cOnn= getConnection1(); //同样先要获取连接,即连接到数据库
try {
String sql = "select * from emp"; // 查询数据的sql语句
st = (Statement) conn.createStatement(); //创建用于执行静态sql语句的Statement对象,st属局部变量
ResultSet rs = st.executeQuery(sql); //执行sql查询语句,返回查询数据的结果集
System.out.println("最后的查询结果为:");
while (rs.next()) { // 判断是否还有下一个数据
// 根据字段名获取相应的值
String name = rs.getString("user_name");
int name_id = rs.getInt("name_id");
String user_salary = rs.getString("user_salary");
//输出查到的记录的各个字段的值
System.out.println(name + " " + name_id + " " +user_salary+ " ");
}
conn.close(); //关闭数据库连接z
} catch (SQLException e) {
System.out.println("查询数据失败");
}
}
}
代码很简单 一个 insert() 一个query()
插入一条数据之后 然后再查询一下,发现怎么都不显示结果 ,有没有大神帮忙看看什么问题。。
好想是rs这个对象一直没有获取到值。。。。
