本文目录一览：
- 1、mySQL在java中的应用
- 2、Java如何连接MySQL数据库进行操作
- 3、MYSQL在JAVA中的使用问题
- 4、如何使用Java访问MySQL数据库
- 5、如何使用Java与Mysql进行数据交互
- 6、如何在Java程序中访问mysql数据库中的数据并进行简单的操作
mySQL在java中的应用
Java连接Mysql详解
Part I: 驱动/数据源类名, URL语法, Connector/J的属性配置.假设你应经安装好了mysql, 和mysql-connector-java-X.X.X-bin.jar
Mysql Connector/J通过com.mysql.jdbc.Driver来实现java.sql.Driver, 同时类名org.gjt.mm.mysql.Driver依旧可用, 以保持向前兼容MM.Mysql.
MySQL的JDBC URL格式如下:
如果没有明确指定host(主机名), 默认为127.0.0.1, 端口号默认是3306
如果不指定数据库名, 不会有默认的数据库, 这样的话, 你可以调用Connection的setCatalog()方法, 或者在SQL中明确指定所用的数据库. 这种情况只在为多个数据库建立工具时有用. 例如建立GUI数据库管理器.
JDBC应该永远不使用USE database来指定数据库, 应该用Connection.setCatalog()方法.
MySQL Connector/J支持fail-over模式, 使用fail-over模式, 必须将connection的autoCommit设置为true.
如果URL的autoReconnect设置为false: Failover会发生在连接初始化时, failback出现在驱动器使第一个主机在此可用时.
如果URL的autoReconnect属性时true, Failover发生在驱动决定connection失败时(在每次查询之前), falls back到第一个主机, 当它决定这个主机在此可用时.
在以上提到的两种情况中, 无论何时你连接到一个"failed-over"服务器, 这个连接将会是制度的, 因此, 修改数据的查询, 将会引发异常.
Configuration properties定义Connctor/J将怎样连接到MySQL服务器. 除了特别声明, 这些属性可以设置在DataSource或Connection object中.
Configuration properties可以按照下面的方式进行设置:
①使用MysqlDataSource或MysqlConnectionPoolDataSource的set*()方法.
②以java.util.Properties的key/value对的形式传递给DriverManager.getConnection() 或Driver.connect()
③作为JDBC URL的参数传给java.sql.DriverManger.getConnection()
java.sql.Driver.connect()或MySQL实现的javax.sql.DataSource setURL() 方法.
注意: 如果你用来确定JDBC URL的机制是XML-based, 你需要使用XML字符 来分隔参数.
Java如何连接MySQL数据库进行操作
下面是一个从 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
ListUser 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);
}
}
}
MYSQL在JAVA中的使用问题
while (result.next())
改成 hashnext（）；
ArrayList list = dao.select(sql);
Iterator iterator = list.iterator();
while(iterator.hasNext()){
oram.FlowEvent t =(oram.FlowEvent)iterator.next();
out.println(t.getEventId()+" "+t.getByname()
类似这样 就不会溢出了
如何使用Java访问MySQL数据库
第1步 获取Java与MySQL的连接器
第2步 将下载的包存放在自己机器上jdk安装目录下面的jre目录下面的lib目录下面的ext目录中，在程序中导入与数据库操作相关的对象
import java.sql.Connection; //导入数据库连接对象
import java.sql.DriverManager; //导入数据库驱动管理对象
import java.sql.ResultSet; //导入数据记录集对象
import java.sql.SQLException; //导入数据SQL操作异常对象
import java.sql.Statement; //导入SQL操作接口对象
第3步：在程序中写入如下内容
String url; //连接数据库的字符串
String sql; //执行数据sql查询操作的字符串
Connection conn; //数据库连接变量
Statement st; //数据库操作对象
ResultSet rs; //数据记录集对象
url = "jdbc:mysql://localhost:3306/test?user=rootpassword="; //在程序中只要修改这句，就可以实现数据库连接
try {
conn = DriverManager.getConnection(url);
st = conn.createStatement();
sql = "select * from test"; //只要修改这句，就可以实现各种查询操作
rs=st.executeQuery(sql); //执行数据查询
while(rs.next())
{
System.out.println(rs.getString(1)); //获得数据表test中第1个字段的数据，该字段为字符串类型
System.out.println(rs.getString(2)); //获得数据表test中第2个字段的数据，该字段为字符串类型
}
rs.close(); //关闭数据记录集
conn.close(); //关闭数据库连接
} catch (SQLException e) {
System.out.println("Error:"+e.toString()+e.getMessage());
}
如何使用Java与Mysql进行数据交互
使用jdbc驱动 六个步骤
创建链接
加载驱动
获取示例
执行sql语句
获取结果集
关闭连接
代码示例
import java.sql.Connection;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;public class DbDemo {
public static void main(String[] args) { // TODO Auto-generated method stub
ResultSet result = null;
Connection con = null;
Statement statement = null; try { // 第0步：将mysql 的jdbcjar包加入到引用库中来
// 第一步：将想要连接的数据库驱动类加载到JVM中来，加载过程中并向DriverManager注册Driver
// 成功加载后，会将Mysql的驱动Driver类的实例注册到DriverManager类中。
//使得下面我们获取Connection只需要通过DriverManager就可以了。我不需要通过每个数据库具体的Driver。
Class.forName("com.mysql.jdbc.Driver").newInstance(); // 第二步,通过DriverManager获取一个和mysql的连接实例con
String JDBCUrl = "jdbc:mysql://localhost:3306/test?useUnicode=truecharacterEncoding=utf-8";//
String userName = "root";
String password = "1557862201"; // 接受一个jdbcurl，username，password；
con = DriverManager.getConnection(JDBCUrl, userName, password); // 第三步：通过con连接获取到Statement实例，执行sql语句
statement = con.createStatement();// statement实例是用于一些不带参数的sql执行，查询，更新，插入，删除操作都可以但是需要构建一个没有占位符的sql字符串
// 第四步，statement执行sql语句，查询到的结果集到ResultSet实例，简单查询，没有where语句的查询
result = statement.executeQuery("select * from student"); // 第五步：从结果集中获取数据
while (result.next()) { // 根据test库中student表格列名读取数据
int id = result.getInt("id");
String name = result.getString("_stuName");
String number = result.getString("_stuNumber");
String Grade = result.getString(result.findColumn("_stuGrade"));
String Address = result.getString(result.findColumn("_stuAddress"));
System.out
.println("name= " + name + " number= " + number + " Grade= " + Grade + " Address= " + Address);
} // 插入语句
// statement.executeUpdate("");
insert(statement); // 执行带参数的查询，有where语句的查询
int id = 2;
executeQuery(con, id); // 执行更新操作
updateDate(con, 2);
delete(con, "XX");// 删除数据行
} catch (ClassNotFoundException e) { // TODO Auto-generated catch block
System.out.println("找不到驱动程序类 ，加载驱动失败！");
e.printStackTrace();
} catch (InstantiationException e) { // TODO Auto-generated catch block
e.printStackTrace();
} catch (IllegalAccessException e) { // TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException ex) { // TODO Auto-generated catch block
System.out.println("SQLException: " + ex.getMessage());
System.out.println("SQLState: " + ex.getSQLState());
System.out.println("VendorError: " + ex.getErrorCode());
ex.printStackTrace();
} finally { // 第六步：释放资源
/**
* 关闭JDBC对象 操作完成以后要把所有使用的JDBC对象全都关闭，以释放JDBC资源，关闭顺序和声 明顺序相反： 1、关闭记录集
* 2、关闭声明 3、关闭连接对象
*/
if (result != null) {// 关闭结果集
try {
result.close();
} catch (SQLException e) { // TODO Auto-generated catch block
e.printStackTrace();
}
result = null;
} if (statement != null) {// 关闭执行sql语句代码块
try {
statement.close();
} catch (SQLException e) { // TODO Auto-generated catch block
e.printStackTrace();
}
statement = null;
} if (con != null) {// 关闭连接
try {
con.close();
} catch (SQLException e) { // TODO Auto-generated catch block
e.printStackTrace();
}
con = null;
}
}
}
如何在Java程序中访问mysql数据库中的数据并进行简单的操作
//加载驱动Class.forName("com.mysql.jdbc.Driver"); //获取数据库连接String user = "root" ,password = "mysql",url="jdbc:mysql://localhost:3306/test??characterEncoding=utf8";Connection connection = DriverManager.getConnection(url, user, password); //增加String sql = "insert into t1(id,name) values(?,?)";PreparedStatement statement = connection.prepareStatement(sql);statement.setString(1, "123123123");statement.setString(2, "jdbc");System.out.println(statement.executeUpdate()); //查询sql = "select * from t1";Statement query = connection.createStatement();ResultSet rs = query.executeQuery(sql);while(rs.next()){System.out.println(rs.getString("id")+","+rs.getString("name"));} //修改sql = "update t1 set name = ? where id = ?";statement = connection.prepareStatement(sql);statement.setString(1, "java");statement.setString(2, "123123123");System.out.println(statement.executeUpdate()); //删除sql = "delete from t1 where id = ?";statement = connection.prepareStatement(sql);statement.setString(1, "123123123");System.out.println(statement.executeUpdate()); connection.close();
