java数据库,怎么在一个文件中连接数据库,另一个文件中执行数据库操作?
我用的jbuilder连接SQL,我看到有的程序中能够在一个比如说是DataBase.java中建立连接然后在另一个java文件中执行updata,insert这样的操作...
我用的jbuilder连接SQL,
我看到有的程序中能够在一个比如说是DataBase.java中建立连接
然后在另一个java文件中执行updata,insert这样的操作
请问是怎么实现的?
在执行操作的那个文件中需要声明什么变量吗?
能不能详细说一下?我刚刚开始学
比如说连接的那个文件中是这样连接的:
public static Connection getConnection(String driver,
String url,
String username,
String password) {
try {
Class.forName(driver);
Connection connection =
DriverManager.getConnection(url, username,
password);
return(connection);
} catch(ClassNotFoundException cnfe) {
System.err.println("Error loading driver: " + cnfe);
return(null);
} catch(SQLException sqle) {
System.err.println("Error connecting: " + sqle);
return(null);
}
}
那另一个文件做什么操作呢?
我的QQ是632105878,如果能详细指导非常感谢! 展开
我看到有的程序中能够在一个比如说是DataBase.java中建立连接
然后在另一个java文件中执行updata,insert这样的操作
请问是怎么实现的?
在执行操作的那个文件中需要声明什么变量吗?
能不能详细说一下?我刚刚开始学
比如说连接的那个文件中是这样连接的:
public static Connection getConnection(String driver,
String url,
String username,
String password) {
try {
Class.forName(driver);
Connection connection =
DriverManager.getConnection(url, username,
password);
return(connection);
} catch(ClassNotFoundException cnfe) {
System.err.println("Error loading driver: " + cnfe);
return(null);
} catch(SQLException sqle) {
System.err.println("Error connecting: " + sqle);
return(null);
}
}
那另一个文件做什么操作呢?
我的QQ是632105878,如果能详细指导非常感谢! 展开
5个回答
展开全部
这是我做的2个javabean
第一个用于对物理数据库地层的连接;
第二个用于用户对数据库的操作;
具体你需要的自己改
第一个:
package com.kiwwor.qq.beans;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
/**
* 数据库操作的JavaBean类,用于对数据库的查询与更新的实现;
* 该类默认的连接的数据库为本地数据库,连接数据库为"qq";
* 该类主要为用户一系列的数据操作提供底层服务。
* @author kiwwor
* @see UserBean
*/
public class Access {
//驱动程序类
private String driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
//连接数据库url
private String connectionUrl="jdbc:sqlserver://localhost:1433;DatabaseName=qq";
//用户名
private String user = "qq";
//用户密码
private String password = "123258741";
//数据库连接对象
private Connection connection = null;
//数据库对象
private Statement statement = null;
//数据集对象
private ResultSet resultSet = null;
public String getDriver() {
return driver;
}
public void setDriver(String driver) {
this.driver = driver;
}
public String getConnectionUrl() {
return connectionUrl;
}
public void setConnectionUrl(String connectionUrl) {
this.connectionUrl = connectionUrl;
}
public String getUser() {
return user;
}
public void setUser(String user) {
this.user = user;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public Connection getConnection() {
return connection;
}
public void setConnection(Connection connection) {
this.connection = connection;
}
public Statement getStatement() {
return statement;
}
public void setStatement(Statement statement) {
this.statement = statement;
}
public ResultSet getResultSet() {
return resultSet;
}
public void setResultSet(ResultSet resultSet) {
this.resultSet = resultSet;
}
/**
* 获取一个连接对象,默认连接对象本地数据库qq。
* @return 连接是否成功
*/
public boolean createConnection() {
boolean b = false;
try {
Class.forName(driver);
connection = DriverManager.getConnection(connectionUrl, user, password);
b = true;
} catch (Exception e) {
e.printStackTrace();
}
return b;
}
/**
* 更新数据库
* @param sql 更新的sql语句
* @return 更新是否成功
*/
public boolean update(String sql) {
boolean b =false;
try {
statement = connection.createStatement();
statement.execute(sql);
b = true;
} catch (Exception e) {
e.printStackTrace();
}
return b;
}
/**
* 执行查询,将查询的结果集给resultmentSet。
* @param sql 查询的sql语句
*/
public void query(String sql) {
try {
statement = connection.createStatement();
resultSet = statement.executeQuery(sql);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 检测结果集是否为空
* @return true为存在记录
*/
public boolean next() {
boolean b = false;
try {
if (resultSet.next()) b = true;
} catch (Exception e) {
e.printStackTrace();
}
return b;
}
/**
* 获得结果集中当前行columnLabel的记录
* @param columnLabel
* @return 值记录
*/
public String getValue(String columnLabel) {
String value = null;
try {
if (resultSet != null) value = resultSet.getString(columnLabel);
} catch (Exception e) {
e.printStackTrace();
}
return value;
}
/**
* 关闭连接对象
*/
public void closeConnection() {
try {
if (connection != null) connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
/**
* 关闭数据库对象
*/
public void closeStatement() {
try {
if (statement != null) statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
/**
* 关闭结果集
*/
public void closeResultSet() {
try {
if (resultSet != null) resultSet.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
/**
* 关闭数据连接对象,数据库对象和数据结果集对象。
*/
public void closeAll() {
closeResultSet();
closeStatement();
closeConnection();
}
/**
* 测试该类函数。
* @param args
*/
public static void main(String[] args) {
Access db = new Access();
if (db.createConnection()) {
System.out.println("测试数据库连接成功.");
String sql = "select id from [user]";
db.query(sql);
int i = 1;
while (db.next()) {
String s = db.getValue("id");
System.out.println("查询用户" + i + ": " + s);
i++;
}
db.closeResultSet();
db.closeStatement();
db.closeConnection();
}
}
}
第二个:
package com.kiwwor.qq.beans;
/**
* 这是一个对用户的数据查询和更新的JavaBean类;
* 该类提供了对用户的密码认证,用户注册等方法。
* @author kiwwor
* @see Access
*/
public class UserBean {
/**
* 对用户的登录认证
* @param id 用户名
* @param password 密码
* @return 认证结果
*/
public boolean isValid(String id, String password) {
boolean b = false;
Access db =new Access();
if (db.createConnection()) {
String sql = "select * from [user] where id=" + id +"and password=" + password;
db.query(sql);
if (db.next()) {
b = true;
}
}
db.closeAll();
return b;
}
/**
* 用来查询该用户在服务器中是否存在
* @param id 用户名
* @return 确认是否存在
*/
public boolean isExit(String id) {
boolean b = false;
Access db =new Access();
if (db.createConnection()) {
String sql = "select * from [user] where id=" + id;
db.query(sql);
if (db.next()) {
b = true;
}
}
db.closeAll();
return b;
}
/**
* 添加用户,该方法必须在<code>isExit(String id)</code>确认的前提下使用,否则可能出现异常
* @param id 新增用户名
* @param password 密码
* @return 确认添加是否成功
*/
public boolean add(String id, String password) {
boolean b = false;
Access db =new Access();
if (db.createConnection()) {
String sql = "insert into [user] (id, password) values (" + id + "," + password + ")";
b = db.update(sql);
}
db.closeAll();
return b;
}
}
第一个用于对物理数据库地层的连接;
第二个用于用户对数据库的操作;
具体你需要的自己改
第一个:
package com.kiwwor.qq.beans;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
/**
* 数据库操作的JavaBean类,用于对数据库的查询与更新的实现;
* 该类默认的连接的数据库为本地数据库,连接数据库为"qq";
* 该类主要为用户一系列的数据操作提供底层服务。
* @author kiwwor
* @see UserBean
*/
public class Access {
//驱动程序类
private String driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
//连接数据库url
private String connectionUrl="jdbc:sqlserver://localhost:1433;DatabaseName=qq";
//用户名
private String user = "qq";
//用户密码
private String password = "123258741";
//数据库连接对象
private Connection connection = null;
//数据库对象
private Statement statement = null;
//数据集对象
private ResultSet resultSet = null;
public String getDriver() {
return driver;
}
public void setDriver(String driver) {
this.driver = driver;
}
public String getConnectionUrl() {
return connectionUrl;
}
public void setConnectionUrl(String connectionUrl) {
this.connectionUrl = connectionUrl;
}
public String getUser() {
return user;
}
public void setUser(String user) {
this.user = user;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public Connection getConnection() {
return connection;
}
public void setConnection(Connection connection) {
this.connection = connection;
}
public Statement getStatement() {
return statement;
}
public void setStatement(Statement statement) {
this.statement = statement;
}
public ResultSet getResultSet() {
return resultSet;
}
public void setResultSet(ResultSet resultSet) {
this.resultSet = resultSet;
}
/**
* 获取一个连接对象,默认连接对象本地数据库qq。
* @return 连接是否成功
*/
public boolean createConnection() {
boolean b = false;
try {
Class.forName(driver);
connection = DriverManager.getConnection(connectionUrl, user, password);
b = true;
} catch (Exception e) {
e.printStackTrace();
}
return b;
}
/**
* 更新数据库
* @param sql 更新的sql语句
* @return 更新是否成功
*/
public boolean update(String sql) {
boolean b =false;
try {
statement = connection.createStatement();
statement.execute(sql);
b = true;
} catch (Exception e) {
e.printStackTrace();
}
return b;
}
/**
* 执行查询,将查询的结果集给resultmentSet。
* @param sql 查询的sql语句
*/
public void query(String sql) {
try {
statement = connection.createStatement();
resultSet = statement.executeQuery(sql);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 检测结果集是否为空
* @return true为存在记录
*/
public boolean next() {
boolean b = false;
try {
if (resultSet.next()) b = true;
} catch (Exception e) {
e.printStackTrace();
}
return b;
}
/**
* 获得结果集中当前行columnLabel的记录
* @param columnLabel
* @return 值记录
*/
public String getValue(String columnLabel) {
String value = null;
try {
if (resultSet != null) value = resultSet.getString(columnLabel);
} catch (Exception e) {
e.printStackTrace();
}
return value;
}
/**
* 关闭连接对象
*/
public void closeConnection() {
try {
if (connection != null) connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
/**
* 关闭数据库对象
*/
public void closeStatement() {
try {
if (statement != null) statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
/**
* 关闭结果集
*/
public void closeResultSet() {
try {
if (resultSet != null) resultSet.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
/**
* 关闭数据连接对象,数据库对象和数据结果集对象。
*/
public void closeAll() {
closeResultSet();
closeStatement();
closeConnection();
}
/**
* 测试该类函数。
* @param args
*/
public static void main(String[] args) {
Access db = new Access();
if (db.createConnection()) {
System.out.println("测试数据库连接成功.");
String sql = "select id from [user]";
db.query(sql);
int i = 1;
while (db.next()) {
String s = db.getValue("id");
System.out.println("查询用户" + i + ": " + s);
i++;
}
db.closeResultSet();
db.closeStatement();
db.closeConnection();
}
}
}
第二个:
package com.kiwwor.qq.beans;
/**
* 这是一个对用户的数据查询和更新的JavaBean类;
* 该类提供了对用户的密码认证,用户注册等方法。
* @author kiwwor
* @see Access
*/
public class UserBean {
/**
* 对用户的登录认证
* @param id 用户名
* @param password 密码
* @return 认证结果
*/
public boolean isValid(String id, String password) {
boolean b = false;
Access db =new Access();
if (db.createConnection()) {
String sql = "select * from [user] where id=" + id +"and password=" + password;
db.query(sql);
if (db.next()) {
b = true;
}
}
db.closeAll();
return b;
}
/**
* 用来查询该用户在服务器中是否存在
* @param id 用户名
* @return 确认是否存在
*/
public boolean isExit(String id) {
boolean b = false;
Access db =new Access();
if (db.createConnection()) {
String sql = "select * from [user] where id=" + id;
db.query(sql);
if (db.next()) {
b = true;
}
}
db.closeAll();
return b;
}
/**
* 添加用户,该方法必须在<code>isExit(String id)</code>确认的前提下使用,否则可能出现异常
* @param id 新增用户名
* @param password 密码
* @return 确认添加是否成功
*/
public boolean add(String id, String password) {
boolean b = false;
Access db =new Access();
if (db.createConnection()) {
String sql = "insert into [user] (id, password) values (" + id + "," + password + ")";
b = db.update(sql);
}
db.closeAll();
return b;
}
}
展开全部
就是把数据库连接、事务处理、接口、数据库操作都分开处理,在执行操作的那个文件里创建一个数据库连接类的对象,调用数据库链接的方法,链接数据库后执行update、insert等操作
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
展开全部
看来你还不熟悉数据库操作,我早先写了个简单的数据操作,增删改查还有sql文件,要的邮箱》qiaole@vip.qq.com
我给你,新手很好用的。
我给你,新手很好用的。
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
展开全部
把数据库连接封装在一个类中
然后在其它类中调用这个类就行了
采用mvc模式也可以
然后在其它类中调用这个类就行了
采用mvc模式也可以
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
展开全部
新手,概念性的东西你还不理解。
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
推荐律师服务:
若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询