DBConnectionManagerjava //连接数据库用的
import javasql;
public class DBConnectionManager {
private String driverName="commicrosoftjdbcsqlserverSQLServerDriver";
private String url="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=demo";
private String user="sa";
private String password="";
public String getDriverName() {
return driverName;
}
public void setDriverName(String driverName) {
thisdriverName = driverName;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
thispassword = password;
}
public String getUrl() {
return url;
}
public void setUrl(String url) {
thisurl = url;
}
public String getUser() {
return user;
}
public void setUser(String user) {
thisuser = user;
}
public Connection getConnection(){
try{
ClassforName(driverName);
return DriverManagergetConnection(url, user, password);
}catch(Exception e){
eprintStackTrace();
return null;
}
}
}
DBSQLManagerjava // *** 作数据库用的
import javasql;
public class DBSQLManager {
protected Connection con=null;//Connection对象
protected Statement stmt=null;//Statement对象
protected ResultSet rs=null;//记录结果集
protected String sql=""; //SQL语句
public DBSQLManager(){
try {
DBConnectionManager dcm=new DBConnectionManager();
con=dcmgetConnection();
//consetAutoCommit(false);//添加事物,既是否自动提交
stmt=concreateStatement();
} catch (SQLException e) {
eprintStackTrace();
}
}
public Statement getStmt(){
return stmt;
}
public Connection getCon(){
return con;
}
public ResultSet getRs(){
return rs;
}
public void setSql(String sql){
thissql=sql;
}
public String getSql(){
return sql;
}
//查找
public void execueQuery(){
try {
rs=stmtexecuteQuery(sql);
} catch (SQLException e) {
eprintStackTrace();
}
}
//更新
public void executeUpdate(){
try {
stmtexecuteUpdate(sql);
} catch (SQLException e) {
eprintStackTrace();
}
}
//关闭
public void close(){
if(rs!=null){
try {
rsclose();
} catch (SQLException e) {
eprintStackTrace();
}
rs=null;
}
if(stmt!=null){
try {
stmtclose();
} catch (SQLException e) {
eprintStackTrace();
}
stmt=null;
}
try {
conclose();
} catch (SQLException e) {
eprintStackTrace();
}
con=null;
}
}
SqlOperatejava //用来调用数据库 *** 作语句
import javasqlResultSet;
import javasqlSQLException;
public class SqlOperate {
//插入,修改,删除
public void insOrModOrDel(String sql){
DBSQLManager dbsm=new DBSQLManager();
dbsmgetStmt();
dbsmsetSql(sql);
dbsmexecuteUpdate();
dbsmclose();
}
//显示
public void display(String sql){
DBSQLManager dbsm=new DBSQLManager();
dbsmgetStmt();
dbsmsetSql(sql);
dbsmexecueQuery();
ResultSet rs=dbsmgetRs();
try {
while(rs!=null&&rsnext()){
Systemoutprint(rsgetObject(1)+"\t");
Systemoutprint(rsgetObject(2)+"\t");
Systemoutprint(rsgetObject(3)+"\t");
Systemoutprintln(rsgetObject(4));
}
dbsmclose();
} catch (SQLException e) {
eprintStackTrace();
}
}
}
SqlMainjava //数据库的测试主函数
public class SqlMain {
public static void main(String[] args){
SqlOperate sqlOpt=new SqlOperate();
// sqlOptinsOrModOrDel("insert into user1 values('qianhaifei',999999,'qianhaifei@163com')");//插入
// sqlOptinsOrModOrDel("update user1 set username='weixiangyang' where id=4");//修改
// sqlOptinsOrModOrDel("delete from user1 where username='weixy2000'");//删除
sqlOptdisplay("select from user1");//显示
}
}
楼主用的时间只需要将数据库 用户名和密码还有数据库表名改一下就行了
其他都是一样的
楼主会改吧/
如果有什么问题的话请百度HI我帮你解决
如果楼主要我的数据库的话请百度HI我我给你就行了
祝楼主早日成功!
读取文件,将文件内容进行变换,转换成你想要的格式。
如果要实现得好一些,需要将数据抽取部分实现一个接口,接口定义类似于:
public interface IDataProvider {
/
@return 读取的数据
/
public [需要的数据类型] readData(限制参数[用于过滤数据、转化数据]);
}
然后用这个接口编写两个实现类,分别是DataFromDatabase、DataFromeFile,在调用层面使用接口调用。
用一个List来模拟连接池存放数据库连接,当有请求使用连接的时候就从List提出来,并listremove(index)。当使用完之后再add回来,如果Listsize为空,就new一个连接。再用一个线程来定时监控List中连接的有效性。期间要记得定义几个变量来记录数据库的连接数、“忙”连接数、空闲连接数、最大连接数、最小连接数等。至于如何建数据库连接,这个我就不说了。
我的大致思路就是这样,我也没实际动手自己写过,不知道成不成功!
以上就是关于急 用java写一个 连接数据库 增删改的例子全部的内容,包括:急 用java写一个 连接数据库 增删改的例子、java程序中,最开始建立了与数据库的连接,是从数据库获取数据,现在要求从文件中获取数据,应如何修改接口、能不能用java,手动的自己写一个数据库连接池等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)