草庐IT

logstash-input-jdbc

全部标签

mysql - 使用 clojure.java.jdbc 从 MySQL 流式传输

根据thereleasenotesfortheMySQLJDBCdriver,当且仅当使用具有并发只读、只进结果且提取大小恰好为Integer/MIN_VALUE的连接时,它才应该流式传输结果。但是,当我尝试准确生成这些条件时(针对[mysql/mysql-connector-java"5.1.21"]),我的SQL查询仍然会永远运行(或者更确切地说,直到它耗尽了JVM的内存并变得繁荣)。(let[query(query-only(fetch-allbig-table))](clojure.java.jdbc/with-connection(get-connection(:dbquer

java - Tomcat JDBC 池中没有足够的空闲连接

给定以下TomcatJDBC连接设置:以及以下MySQL参数:max_connections=100000wait_timeout=31536000interactive_timeout=31536000我希望连接池中始终至少有50个空闲连接。但真正发生的是:服务器启动时有50个连接,一段时间后,除了最后一个连接外,所有连接都挂掉了。是不是我的设置有误?环境:Linux3.464位OpenJDK7Tomcat7MySQL5.5 最佳答案 我不是MySQL专家,但有一段时间使用TomcatJDBC和Oracle。只要应用程序未关闭,空

java - 如何使用带有 MYSQL JDBC 驱动程序的 SimpleJdbcInsert 和 executeBatch 获取生成的 key ?

我想一次插入多条记录,并获取每条记录的id,它是自动递增的。我正在按照以下方式进行操作,但获取更新的行数而不是生成的键,在这种情况下为id。publicint[]addPersons(Listpersons){SqlParameterSource[]records=newBeanPropertySqlParameterSource[persons.size()];inti=0;for(Personperson:persons){records[i]=newBeanPropertySqlParameterSource(person);i++;}SimpleJdbcInsertinsert

mysql - 使用 ElasticSearch 同步 MySQL 插入、更新和删除操作

这是一个相当常见的elasticsearch(ES)案例:由于ES接近实时,我们希望尽可能接近实时地将它与我们的MySQL同步。初始表已导入到索引中并且工作正常,但现在我们需要跟踪插入、更新和删除新记录,这是我们有问题的地方。导入由elasticsearch-jdbc导入器完成。它可以有一个间隔参数来定期轮询数据,但是:我们不能将字段添加到负责获取新/更新行的数据库,我们希望有更多的原子操作,如数据库插入行->ES插入文档、数据库更新行->ES更新文档等。可能满足我们需求的两个选项:Logstashwithlogstash-input-jdbcpluginDatabusforMySQL

java - jdbc的registerOutParameter中的sqlType是什么意思?

我正在使用jdbcCallableStatement在MySQL数据库中执行程序。在编写单元测试时,我遇到了关于registerOutParameter方法的奇怪行为。使用的SQL过程PROCEDURETEST_DOUBLE(OUTvalDOUBLE)BEGINSETval=2.5;ENDPROCEDURETEST_TEXT(OUTvalTEXT)BEGINSETval='test';END测试statement=connection.prepareCall("CALLTEST_DOUBLE(?)");statement.registerOutParameter("val",java.

mysql - Glassfish 没有正确导入 mysql jdbc

我正在尝试将我的开发环境从EclipseLuna更新到Neon。我已经克隆了一个jersey-quickstart-webapp的Git存储库,它现在可以正确部署。但是,当我尝试从网页访问该应用程序时,它会在服务器控制台中抛出以下错误:2017-04-01T14:43:57.528+0100|Warning:Thefollowingwarningshavebeendetected:WARNING:UnknownHK2failuredetected:MultiExceptionstack1of1javax.enterprise.inject.CreationExceptionCaused

java - com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException : Cannot add or update a child row: a foreign key constraint fails

当我想插入一些数据时,我经常遇到错误项目类@Entity@NamedQueries({@NamedQuery(name="Project.findAll",query="SELECTpFROMProjectp"),@NamedQuery(name="Project.findByTitle",query="SELECTpFROMProjectpWHEREp.title=:title")})publicclassProjectimplementsSerializable{@Id@GeneratedValue(strategy=GenerationType.IDENTITY)privatei

IDEA插件之输入法自动切换【Smart Input Source】

MAC系统推荐快捷键针对输入切换无需快捷键,但是在某些场景下比如GitDiff的时候可能存在自动跳转到源文件的情况,这种时候需要手动关闭自动切换功能,给作者提了个建议对这种场景进行优化。建议使用的快捷键,C代表关闭,O代表打开。介绍解决什么问题对于母语为中文的开发者,写代码过程中经常需要在中/英输入法之间进行切换,而且由于不清楚当前处于哪种输入状态,有时输入到一半发现输入法错了,删除后重新输入,严重影响了编码效率。还有在IdeaVim命令模式时必须使用英文输入法,由于不清楚当前处于哪种输入状态,而在IdeaVim命令模式下误用中文输入法,导致效率严重降低。其实,在哪种情况需要使用哪种输入法是可

JDBC连接Oracle异常-Connection Reset By Peer

场景描述在生产环境通过JDBC连接oracle数据库,80%的几率会出现以下异常:JDBCSSLConnectionFailsWithSEVERE:IOError:ConnectionResetByPeer,ConnectLapse1Ms.,AuthenticationLapse0Ms.(DocID2747530.1)TheNetworkAdaptercouldnotestablishtheconnection是有时候没问题,有时候有问题。服务器配置:ARM架构服务器,麒麟操作系统。解决根据ConnectionResetByPeer,ConnectLapse1Ms.,Authenticatio

java - 使用mysql的jdbc连接

importjava.sql.*;publicclassMysqlConnect{publicstaticvoidmain(String[]args){System.out.println("MySQLConnectExample.");Connectionconn=null;Stringurl="jdbc:mysql://localhost:3306/";StringdbName="sint";Stringdriver="com.mysql.jdbc.Driver";StringuserName="root";Stringpassword="najeer";try{Class.for