According to the link above, you can set up an automatic task that periodically purges these orphaned messages.
If you set the value of "NumberOfDaysToKeep" to a low value (0 for all messages at the time of purge) and set up a Task to purge messages on a periodic basis, this should meet your needs.
Can I get more context about what you are trying to do? Are you trying to insert a stream to the datasource or retrieve a stream from the datasource or just make a blob in general?
If you have a java.sql.PreparedStatement and what seems to be a java.io.InputStream subclass (since you can call read() on it), why not utilize java.sql.PreparedStatement.setBinaryStream(int parameterIndex, InputStream x)? I am not sure which version of com.intersys.jdbc.CacheDriver you are using, but it is likely that your driver version has that API supported.
try (
java.sql.Connection cnxn = DriverMasnager.getConnection(url, cnxnProps);
java.sql.PreparedStatement pstmt = cnxn.prepareStatement(
"INSERT INTO tableWithBlobField VALUES(?)");
){
pstmt.setBinaryStream(1, binaryStreamFromRestAPI);
pstmt.executeUpdate();
}
https://docs.intersystems.com/irislatest/csp/docbook/Doc.View.cls?KEY=GSQL_procedures
I believe this page explains why, and I will also try my best to condense information:
Hello Elize,
Based on the error that you are receiving, it seems that you might be executing a direct SQL statement instead of a parameterized statement. This means that your DateTime object (new DateTime(1900, 1, 1, 12, 03, 30) is being converted to a String and this, in effect, bypasses our ODBC driver's handling of specific nuances regarding temporal types.
%Library.Time expects either a proper time string (denoted by the regex /(\d{2}:){2}\d{2}(.\d*)?/) or an appropriate $HOROLOG value and for this reason, you get SQL error -147.
Nonetheless, there are several solutions you can go about this:
Hello Magnus,
I recommend that you use a SQL CALL instead of IRIS Native for .Net.
The following CALL query should work: CALL SYS.Mirror_MemberStatusList('NAMEOFTHEMIRROR') and this is no different than using a stored procedure (because MemberStatusList is a class query).
If you do not have a connection to %SYS where SYS.Mirror exists , but the user for your existing connection does have privileges to access %SYS, you can write a wrapper stored procedure something similar to:
CREATE PROCEDURE MirrorMemberStatusList(IN MirrorName %String) RESULT SETS LANGUAGE OBJECTSCRIPT
{
:#Include %occResultSet
new $NAMESPACE
set $NAMESPACE="%SYS"
$$$ResultSet("CALL Sys.Mirror.MemberStatusList('" _ MirrorName _ ')")
}Hello Marcio,
The answer you are looking for can be found in the SerialBlob javadocs: this is the only known provided implementation of the java.sql.Blob interface. In particular, you would like the the SerialBlob(byte[]b) constructor to create a blob in Java.
The noted difference between %SQL.StatementResult.%Get() and %Library.ResultSet.%Get() is regarding the actual column names, not the values they contain.
Given that I am using InterSystems IRIS, but here is how I reproduced your example (I don't use a left-join, but they should behave the same)
CREATE TABLE testTable("Column A" INT, "Column B" INT, "Column C" INT, "Column D" INT)
INSERT INTO testTable VALUES(1,2,3,4)
INSERT INTO testTable VALUES(1 NULL, NULL,4)
-------------------------
USER>set stmt = ##class(%SQL.Statement).%New()
USER>set query = 1, query(1) = "SELECT * FROM testTable"
USER>write stmt.%Prepare(.query)
1
USER>set rs = stmt.%Execute()
USER>write rs.%Next()
1
USER>write rs.%Get("Column B")
2
USER>write rs.%Next()
1
USER>zwrite rs.%Get("Column B")
""
USER>do $system.Status.DisplayError(rs.%Get("Column E"))
DO $SYSTEM.Status.DisplayError(rs.%Get("Column E"))
^
<PROPERTY DOES NOT EXIST> *Column E,%sqlcq.USER.cls15As you can see, %SQL.StatementResult.%Get() should only throw an error if you pass in an invalid column name such as "Column E" in the code snippet above.
I recommend that you check the %SQL.StatementMetadata to check if the columns exist in the first place.
USER>set rsmd = rs.%GetMetadata() USER>set columns = $LB() USER>for i=0:1:rsmd.columnCount-1 set $li(columns,i+1)=rsmd.columns.GetNext(i).colName
Once you have columns populated, you can use $LISTFIND to determine whether or not the column exists.
If you cannot do the above then you can wrap the use of %SQL.StatementResult.%Get() with a try-catch block as seen below:
while(rs.%Next()) {
try {
set var = rs.%Get(columnName)
} catch {
set var = ""
}
}I do not recommend the try-catch fallback assignment
To unfreeze:
Then execute $system.SQL.Purge()
That should unfreeze everything and delete all CQs.
^PERFMON (https://docs.intersystems.com/irislatest/csp/docbook/DocBook.UI.Page.cls?KEY=GCM_perfmon)
^MONLBL (https://docs.intersystems.com/irislatest/csp/docbook/Doc.View.cls?KEY=GCM_monlbl)
^GLOSTAT (https://docs.intersystems.com/irislatest/csp/docbook/Doc.View.cls?KEY=GCM_glostat)
From what you mention, I believe ^GLOSTAT or ^PERFMON are two utilities that you will find very useful.
w $system.Status.GetErrorText(##class(SomeClass).IsNonNullCustomerID("1234"))
Is this Dynamic or Embedded SQL?
I am trying to run this in the server management portal and it does not work with a stub table.
Use a Java Gateway if that is available to you.
There's a JDBC example (it uses InterSystems' JDBC driver, but the code can be replaced with the proper driver if you're familiar with JDBC since it users DriverManager) under %Net.Remote.Java.Test in the JDBC method
Having the jar in the same directory as the application may not be enough to ensure that the JAR is loaded into the vm.
How are you running the logstash application? Is it through a GUI or CLI? If CLI, can you paste (with any sensitive information redacted ofc) the command your running?
You might have success looking at this stackoverflow post: https://stackoverflow.com/questions/53237741/logstash-com-mysql-jdbc-driver-not-loaded
Your issue is with Logstash it seems.
%0AmBs1+1^%sqlcq.SMTKTUAT.cls498.1 is the label and offset of where in the cached query the error was thrown, but not the actual error itself.
How are you running the SQL query? ODBC? JDBC? Embedded? Dynamic? If ODBC or JDBC, do you have any logs?
Alternatively, try purging your cached queries ($ysstem.SQL.Purge()) and reattempt. There could be an issue with the cached query itself.
$system.SQL.Purge() is objectscript code. Sorry for assuming you were using IRIS Terminal.
If you're using JDBC, please edit your JDBC url to look like the following:
jdbc:IRIS://host:port/namespace/logfile
logfile will be written to the current directory of wherever the JDBC process in launched (i.e. the working directory of the JVM process).
The logfile will be in the working directory of wherever the JDBC process was launched, not necessarily your local working directory. If you're working from a Unix system, you can specify a full filepath. If you're working from Windows, then unfortunately, that will be an issue. A bug was recently fixed that allows the full filepath to be specified via the URL but that was only fixed recently in IRIS.
SELECT %ODBCOUT(TO_DATE('5/8/2020','MM/DD/YYYY'))
will also work.
If you run "jar -tf" onto the jar file, does the directory structure of the jar file match example/KafkaBusinessOperation?
What Java version are you using?
Can you provide the output of `jar -tf <name of your jar file>`?
NoClassDefFoundError is usually an indication that the classpath (as defined by the classloading operations performed) is not properly setup.
If your jar file isn't properly structured, that's the problem.
I want to make sure, AppSeguimientoAnadidaReferenciaJARSexternos.jar is included on the "Additional Paths".
I searched the Operation's XML definition and I didn't see it there.
I just did some research; Jars nested within Jars is actually a use-case that is not supported by Java.
https://bugs.java.com/bugdatabase/view_bug.do?bug_id=4735639
https://stackoverflow.com/questions/12357136/reference-jars-inside-a-jar/12357544
Supposedly there are Maven plugins you can use to help resolve your problem; but this is a well-known Java issue.
https://cedocs.intersystems.com/latest/csp/docbook/DocBook.UI.Page.cls?…
Documents exactly what you're asking. According to official documentation, this is expected behavior.
If you're using IRIS 2020.2.0 or above (both target and source instances must be ^2020.2.0), you can try to leverage %Net.DB.Iris. It's an implementation of IRIS Native for Java/.NET/Python/Node except for Objectscript. If there is enough interest for features like %Net.DB.Iris, @Bob Kuszewski would love to hear about it and communicate that interest over to the development teams!
Create a simple %Status like
set status = $system.Status.Error(5001, "This is an error")and if you do
zwrite status status="0 "_$lb($lb(5001,"This is an error",, ....."
I cut out a significant chunk (...) because it's not relevant.
You can see that the first character in status is "0", that is because if you try a unary operator
+status, -status, 'statusIt will evaluate to the integer 0 and effectively work as a boolean flag. The part that matters is after the "0" inside the $listbuild.
The first element of $listbuild is the error code, followed by the message.
Because you set Test to 0 and nothing else, Objectscript recognizes that as a failure condition but has absolutely no information to provide beyond that. The recommendation is that you properly assign Test as a fully qualified %Status or change it to a %String where its value is equal to
$system.Status.GetErrorText(/* some %Status instance*/)
$system.OBJ.IsUpToDate()might fit the bill for your first question.
set sc = $system.OBJ.GetClassList(.classes)
set cls="", outdated=""
for {
set cls = $order(classes(cls))
quit:(cls="")
if '$system.OBJ.IsUpToDate(cls) set outdated = outdated _ $lb(cls)
}
for i=1:1:$listlength(outdated) {
write $listget(outdated, i)
}should work for your 2nd question (documentation here: https://docs.intersystems.com/irislatest/csp/documatic/%25CSP.Documatic…)
You can run a query like SELECT * FROM someTable ORDER BY %ID and it will order by the row ID without including it as part of the result set. Ultimately we would need more information (like the query you're running) to provide additional answers, but ORDER BY %ID sounds like what you want to use.