设为首页 收藏本站
查看: 600|回复: 0

[经验分享] java访问mysql 数据库 表 的列名称

[复制链接]

尚未签到

发表于 2016-10-17 03:35:24 | 显示全部楼层 |阅读模式
  最近忙着开发拎图网,图片社区 喜欢的朋友常来逛逛。谢谢.
  工作中,有的存储过程里调用:

INSERT IGNORE INTO `box_phone_warning_imei` SELECT [size=1em]*[size=1em] FROM `box_log`.`box_local_phone_log` WHERE id  <> v_id and imei = v_group and (mac <> v_group2 or createTime<>v_group3);
现在为了用table里的字段名 替换* ,达到下面的结果,以避免box_phone_warning_imei和box_local_phone_log字段不一致时导致数据拷贝失败。
INSERT IGNORE INTO `box_phone_warning_imei` SELECT id,imei,mac,phoneNum,phoneModel,phoneVendor,appSuccessNum,appSuccessIds,appSuccessNames,appFalseNum,appFalseIds,appFalseNames,boxId,channelId,fatherChannelId,province,city,createTime,updateTime,statType,success,errorMsg,albumId,address,realIp FROM `box_log`.`box_local_phone_log` WHERE id  <> v_id and imei = v_group and (mac <> v_group2 or createTime<>v_group3);
  
  面对以上这么简单的需求不可能手动去,数据表里一个字段一个字段的copy下来组合成一个string吧,这样体力活不应该是猿人干的。用jdbc来帮忙吧。
  

package jdbc.test;
import java.sql.*;
/**
* @author jone
*
*/
public class JDBCDemo {
static String user = "root";
static String password = "88888888";
static String url = "jdbc:mysql://localhost:3306/box_log_copy";
static String tableName="";              
static String driver = "com.mysql.jdbc.Driver";
static Connection con = null;
static {
try {
Class.forName(driver);
initInfo(2);
con = DriverManager.getConnection(url, user, password);
} catch (Exception e) {
e.printStackTrace();
}
}
//想切换不同库里的表,配置以下url 和tableName就OK了。
private static void initInfo(int type) {
switch (type) {
case 1:
url = "jdbc:mysql://localhost:3306/box_oms_copy";
tableName = "box_local_phone_sale_sum";
break;
case 2:
url = "jdbc:mysql://localhost:3306/box_log_copy";
tableName = "[size=1em]box_local_test_log[size=1em]";
break;
default:
url = "jdbc:mysql://localhost:3306/box_log_copy";
tableName="box_mobile_log";
break;
}
}

/**
* @param args
*/
public static void main(String[] args) {

String sqlstr = "select * from "+tableName;
querySql(tableName, sqlstr);
}

private static void querySql(String tableName, String sqlstr) {
Statement stmt = null;
ResultSet rs = null;
try{
stmt = con.createStatement();
// sqlstr = "insert into "+tableName+" values ('20140113','jone',01)";
// stmt.executeUpdate(sqlstr);

rs = stmt.executeQuery(sqlstr);
StringBuilder sb=new StringBuilder();
ResultSetMetaData rsmd = rs.getMetaData();
int j = 0;
j = rsmd.getColumnCount();
for(int k = 0; k<j; k++)
{
// System.out.print(rsmd.getCatalogName(k+1));
System.out.print(rsmd.getColumnName(k+1));
System.out.print("\t");
sb.append(rsmd.getColumnName(k+1)).append(",");
}
System.out.println();
System.err.println(sb.deleteCharAt(sb.length()-1).toString());
// 以下注释打开后可以输出每行记录的值。
//            while(rs.next())
//            {
//               for(int i=0;i<j;i++)
//                {
//                    System.out.print(rs.getString(i+1));
//                     System.out.print("\t");
//                }
//                 System.out.println();
//            }
}catch(SQLException e2)
{
System.out.println("数据库存在异常!");
System.out.println(e2.toString());
}
finally
{
try
{
colseConection(stmt, rs);
}
catch(SQLException e)
{
System.out.println(e.toString());
}            
}
}

private static void colseConection(Statement stmt, ResultSet rs)
throws SQLException {
if(rs != null) rs.close();
if(stmt != null) stmt.close();
if(con != null) con.close();
}
}
  
  如果一个数据表结构是:

CREATE TABLE `box_local_test_log` (
`id` bigint(11) NOT NULL AUTO_INCREMENT ,
`imei` varchar(80) DEFAULT NULL ,
`mac` varchar(50) DEFAULT NULL ,
`phoneModel` varchar(80) DEFAULT NULL ,
`phoneVendor` varchar(50) DEFAULT NULL ,
`appId` int(11) DEFAULT NULL ,
`boxId` int(11) DEFAULT NULL ,
`channelId` int(11) DEFAULT NULL ,
`fatherChannelId` int(11) DEFAULT NULL,
`province` varchar(30) DEFAULT NULL ,
`city` varchar(30) DEFAULT NULL ,
`createTime` datetime NOT NULL DEFAULT '0000-00-00 00:00:00' COMMENT '创建时间',
`updateTime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
`statType` int(4) DEFAULT '2' ,
`success` bit(1) DEFAULT NULL,
`errorMsg` varchar(1000) DEFAULT NULL ,
PRIMARY KEY (`id`,`createTime`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8
  执行后。输出的结果:

id,imei,mac,phoneModel,phoneVendor,appId,boxId,channelId,fatherChannelId,province,city,createTime,updateTime,statType,success,errorMsg
  这个表的列就组合成一个String了,其实以上没什么技术含量,只是个简单的demo,大家可以自己扩展得到自己想到的结果。
  
  以上只需要mysql-connector-java-5.1.21.jar /附件中有。
  
  
  
  
  
  
  
  

运维网声明 1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址:https://www.yunweiku.com/thread-287013-1-1.html 上篇帖子: matlab-VQB操作MYSQL数据库及中文乱码解决 下篇帖子: (转)使用mysqladmin ext了解MySQL运行状态
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服E-mail:kefu@iyunv.com 客服QQ:1061981298


QQ群⑦:运维网交流群⑦ QQ群⑧:运维网交流群⑧ k8s群:运维网kubernetes交流群


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来,其版权均归原作者及其网站所有,我们尊重他人的合法权益,如有内容侵犯您的合法权益,请及时与我们联系进行核实删除!



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表